Outbox
Persistence-agnostic factory that produces a new OutboxMessage instance matching the storage backend in use (JPA entity, Mongo document, Cassandra row, …).
Functions
Link copied to clipboard
abstract fun create(topic: String, key: String, payload: ByteArray, sagaId: String?, eventId: String?): OutboxMessage
Builds a new outbox message in OutboxStatus.PENDING.