Package org.acemq.amqp.patterns

@NullMarked package org.acemq.amqp.patterns

Distributed messaging patterns as things you configure rather than reimplement.

Each pattern here is one that services otherwise rebuild, usually incompletely: an idempotent consumer that marks before the work instead of after, an outbox that commits the message separately from the data it describes.

Class	Description
ClaimCheckCodec	Keeps large payloads off the broker.
ConnectionSupplier	Hands back the JDBC connection the calling code is already using for its own work.
FilesystemClaimCheckStore	A claim-check store on a filesystem.
InMemoryClaimCheckStore	A claim-check store in a map, for tests.
InMemoryIdempotencyStore	An idempotency store held in this process's memory, bounded by size and age.
JdbcIdempotencyStore	An idempotency store in a database table, shared by every consumer that points at it.
JdbcOutboxStore	An outbox kept in a relational table, in the same database as the work it accompanies.
JdbcSchemaRegistry	A schema registry in a database table.
OutboxRelay	Moves messages out of the outbox and into the broker.
Saga<T>	A sequence of steps where each one knows how to undo itself.
Saga.Builder<T>	Collects the steps of a Saga.
SagaResult	What a saga did.
Scheduler	Delivering a message later.