All Classes and Interfaces

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.
AceMq	The entry point: one connection to one broker, and the publishers and consumers built on it.
AceMqActuator	Serves AceMQ's metrics, health and version over HTTP.
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.
Acknowledger	Settles one delivery.
ActuatorOptions	How an AceMqActuator is exposed.
ActuatorOptions.Builder	Collects the settings.
ApplyMode	How much a topology apply is allowed to do.
AvroCodec	Reads and writes Avro.
BuiltInCodecProviders	The two formats that need no library, announced to the registry.
BuiltInCodecProviders.Bytes	Announces BytesCodec as bytes.
BuiltInCodecProviders.Text	Announces StringCodec as text.
BytesCodec	Passes bytes through untouched.
Capability	A feature a broker either supports or does not.
CertsMojo	Writes throwaway TLS certificates for local development.
ClaimCheckCodec	Keeps large payloads off the broker.
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.
Codecs	Finds the codecs on the classpath and names the ones used by default.
CompositeCodec	Writes in one format and reads several.
ConfirmResult	The broker's answer to one publish.
ConnectionBlockedException	The broker has stopped accepting publishes, and waiting for it to resume ran out of time.
ConnectionConfig	Everything a transport needs in order to open a connection.
ConnectionConfig.Builder	Builds ConnectionConfig instances.
ConnectionSupplier	Hands back the JDBC connection the calling code is already using for its own work.
ConsumeContext	A message about to be handled, as an interceptor sees it.
ConsumeInterceptor	Runs around every handler on a connection.
ConsumerGroup	Several consumers on one queue, resized while the application runs.
ConsumerGroupBuilder<T>	Says how many consumers to run and how much each may hold, and then starts them.
ConsumerOptions	How a consumer should behave.
Credentials	A username and a secret.
CredentialsProvider	Supplies the credentials to connect with, every time a connection is made.
DefaultPublisher<T>	Publishes to one destination, waiting for the broker to confirm every message.
DeliveryListener	Receives deliveries from a subscription.
DevelopmentCertificates	Generates a throwaway certificate authority and the certificates a local broker and client need, so that running with TLS on a developer's machine is one command rather than an afternoon with openssl.
DevelopmentCertificates.Result	What DevelopmentCertificates.generate(java.nio.file.Path, java.lang.String, char[], java.time.Duration) wrote.
EncryptedCodec	Encrypts whatever another codec produced, so the broker holds ciphertext.
EncryptionKey	A key and the name messages will refer to it by.
Envelope	The AceMQ metadata that travels with every message, independent of payload and broker.
Envelope.Builder	Builds Envelope instances.
FilesystemClaimCheckStore	A claim-check store on a filesystem.
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.
InboundDelivery	A message handed up from the broker, still encoded.
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.
InMemorySchemaRegistry	A registry held in this process's memory.
InMemoryTransport	A transport that runs entirely in the process, for tests that should not need Docker.
Itinerary	An itinerary a message carries with it, naming every stop rather than every step.
Itinerary.Stop	One stop on an itinerary.
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.
JsonCodec	Reads and writes JSON, using Jackson.
JsonCodecProvider	Announces JsonCodec to the engine as json.
Keyring	The keys a service can write with and the keys it can read with.
Keyring.Builder	Collects keys for a Keyring that does not change while the process runs.
Keyring.StaticKeyring	A keyring over a fixed map.
Keys	Getting an AES key from the shapes one usually arrives in.
Message<T>	A message as a handler sees it: the decoded payload plus everything known about how it arrived.
MessageConsumer	A running consumer.
MessageHandler<T>	Handles one message.
MetricNames	The metric and span names AceMQ emits.
MicrometerSupport	Creates the Micrometer sink, in a class of its own.
OpenTelemetrySupport	Creates the OpenTelemetry sink, in a class of its own.
OrderedQueue<T>	Messages that share a key are handled in the order they were sent.
OrderedQueue.OnFailure	What happens when a handler fails.
OrderedQueueBuilder<T>	Says how a stream of messages is partitioned, and then declares it.
OutboundMessage	A message on its way to the broker, already encoded.
OutboundMessage.Builder	Builds OutboundMessage instances.
OutboxRecord	One message waiting in the outbox: where it is going, what it says, and how it has fared.
OutboxRelay	Moves messages out of the outbox and into the broker.
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.
Pipeline<T>	A chain of steps, each its own queue.
PipelineBuilder<T,C>	Declares the steps of a pipeline, in order, threading the types along the chain.
ProtobufCodec	Reads and writes Protocol Buffers.
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.
PublishOptions	How a message should be published.
PublishResult	The outcome of one publish, after the broker has confirmed it.
PulledMessage	One message taken off a queue by TransportConnection.receive(java.lang.String, java.time.Duration), and the means to settle it.
QueueCheck	What a broker says about a queue somebody is about to declare.
QueueCheck.Result	Which of the four answers this is.
QueueType	The kind of queue to declare.
RabbitMqTransport	AMQP 0-9-1 transport backed by the RabbitMQ Java client.
Replay	Moves messages out of a dead-letter queue or parking lot and back to the queue they failed in.
Requester	Asks a question and waits for the answer.
RequestTimedOutException	No reply arrived in time.
Responder	The other end of Requester: reads a request, computes an answer, sends it back.
ResponderFailedException	The responder answered, and the answer was a failure.
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.
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.
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.
Security	How a connection is protected.
Security.Mode	What a connection does about transport security.
SecurityConfigurationException	Something about the security configuration is wrong.
Step<I,O>	One stage of a pipeline: a message in, the next payload out.
StreamConsumer	A running read of a stream.
StreamOffset	Where in a stream a consumer starts reading.
StreamOptions	How a stream should be read.
StreamOptions.OnFailure	What to do when a handler throws.
StreamReader<T>	Says where to start reading a stream, and then starts.
StringCodec	Reads and writes UTF-8 text.
Subscription	A live consumer registration.
Telemetries	Builds the telemetry sink for a connection.
Telemetry	Where AceMQ reports what it is doing.
Telemetry.Scope	An operation in progress.
TomlCodec	Reads and writes TOML.
TomlCodecProvider	Announces TomlCodec to the engine as toml.
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.
TopologyPlanner	Works out what a Topology would change before changing it.
Transport	A binding to one messaging protocol.
TransportConnection	An open connection to one broker.
TransportException	Raised when a broker interaction fails in a way the caller cannot correct.
XmlCodec	Reads and writes XML.
XmlCodecProvider	Announces XmlCodec to the engine as xml.
YamlCodec	Reads and writes YAML.
YamlCodecProvider	Announces YamlCodec to the engine as yaml.