shared-messaging-kafka/com.vertyll.veds.shared.messaging.kafka.persistence.inbox

Package-level declarations

Types

@Entity

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

A claim in the idempotent-receiver ledger: one consumer group has handled one event.

@Component

Binds the persistence-agnostic inbox ports to JPA.

@Repository

Spring Data access to the idempotent-receiver ledger. A service enables it by naming this package in @EnableJpaRepositories.