Package org.acemq.amqp.api

@NullMarked package org.acemq.amqp.api

The public AceMQ AMQP API.

This package carries no third-party dependencies by design. It is the module from which every other language port is transliterated, so anything added here becomes a cross-language commitment.

Class	Description
AceFatalException	Signals a failure that retrying cannot fix, such as a message that will never be valid for this handler.
AceHeaders	The message header names that make up the AceMQ cross-language contract.
AceMqException	Base type for every exception this library raises.
AceRetryableException	Signals a failure worth retrying: the message is sound but the attempt did not succeed, typically because a dependency was briefly unavailable.
Ack	What should happen to a delivery once a handler has looked at it.
AckAwareHandler<T>	Handles one message and states the outcome explicitly.
ApplyMode	How much a topology apply is allowed to do.
Capability	A feature a broker either supports or does not.
ClaimCheckStore	Where a payload too large for a broker actually goes.
Codec	Turns payloads into bytes and back.
CodecProvider	Announces a codec to the engine, so that a format can be chosen by name.
ConsumeContext	A message about to be handled, as an interceptor sees it.
ConsumeInterceptor	Runs around every handler on a connection.
Envelope	The AceMQ metadata that travels with every message, independent of payload and broker.
Envelope.Builder	Builds Envelope instances.
IdempotencyStore	Remembers which messages have already been handled, so handling one twice does not happen twice.
IdempotencyStore.ClaimResult	What IdempotencyStore.tryClaim(java.lang.String) found.
Message<T>	A message as a handler sees it: the decoded payload plus everything known about how it arrived.
MessageHandler<T>	Handles one message.
MetricNames	The metric and span names AceMQ emits.
OutboxRecord	One message waiting in the outbox: where it is going, what it says, and how it has fared.
OutboxStore	Holds messages that must be published if, and only if, the work that produced them was committed.
Partitioning	Decides which partition an ordering key belongs to.
PublishContext	A message about to be published, as an interceptor sees it.
Publisher<T>	Sends messages of one type to one destination.
PublishFailedException	Raised when a publish did not result in a message the broker took responsibility for and could route.
PublishingPausedException	Publishing was paused on this connection, so the message was not sent.
PublishInterceptor	Runs around every publish on a connection.
PublishResult	The outcome of one publish, after the broker has confirmed it.
RetryPolicy	When, and how often, a failed message should be tried again, and where the waiting happens.
RetryPolicy.Wait	How long before the next attempt, and where the message spends it.
RoutingSlip	Where a message is going, carried by the message.
SchemaDefinition	A schema as a registry sees it: some text, and enough about it to know what the text is.
SchemaRegistry	Turns a schema into a small integer and back.
Step<I,O>	One stage of a pipeline: a message in, the next payload out.
StreamOffset	Where in a stream a consumer starts reading.
Telemetry	Where AceMQ reports what it is doing.
Telemetry.Scope	An operation in progress.
Topology	A topology as data: what exchanges, queues and bindings should exist.
Topology.BindingSpec	A binding that should exist.
Topology.Builder	Builds a Topology.
Topology.ExchangeSpec	An exchange that should exist.
Topology.QueueSpec	A queue that should exist.
TopologyPlan	What applying a Topology would do, worked out before anything is done.
TopologyPlan.Action	One item of a plan.
TopologyPlan.Kind	What a plan proposes to do about one item.