Package org.acemq.amqp.core

@NullMarked package org.acemq.amqp.core

The protocol-agnostic engine.

Everything with an opinion lives here: publishing with confirms, the consumer runtime, envelope mapping, codecs and, as they arrive, retries and topology planning. The core talks only to the transport SPI, which is why the same engine serves AMQP 0-9-1 and AMQP 1.0.

Class	Description
AceMq	The entry point: one connection to one broker, and the publishers and consumers built on it.
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.
Codecs	Finds the codecs on the classpath and names the ones used by default.
CompositeCodec	Writes in one format and reads several.
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.
DefaultPublisher<T>	Publishes to one destination, waiting for the broker to confirm every message.
Itinerary	An itinerary a message carries with it, naming every stop rather than every step.
Itinerary.Stop	One stop on an itinerary.
MessageConsumer	A running consumer.
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.
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.
PublishOptions	How a message should be published.
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.
StreamConsumer	A running read of a stream.
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.
Telemetries	Builds the telemetry sink for a connection.
TopologyPlanner	Works out what a Topology would change before changing it.