shared-infrastructure/com.vertyll.veds.sharedinfrastructure.kafka.entity

Package-level declarations

Types

@MappedSuperclass

abstract class BaseOutbox(var id: Long? = null, eventId: String = UUID.randomUUID().toString(), var topic: String, var key: String, var payload: ByteArray, status: OutboxStatus = OutboxStatus.PENDING, errorMessage: String? = null, var createdAt: Instant = Instant.now(), processedAt: Instant? = null, retryCount: Int = 0, lastRetryAt: Instant? = null, var sagaId: String? = null, var version: Long? = null) : OutboxMessage

JPA @MappedSuperclass providing the column mapping for a Kafka outbox row.

BaseProcessedEvent

@MappedSuperclass

abstract class BaseProcessedEvent(var id: Long? = null, var eventId: String, var consumerGroup: String, var processedAt: Instant = Instant.now()) : ProcessedEvent

JPA @MappedSuperclass providing the column mapping for a row in the per-service processed_event table used by the consumer-side idempotent receiver pattern.