Package org.acemq.amqp.transport

@NullMarked package org.acemq.amqp.transport

The contract a broker binding must satisfy.

Everything here is deliberately small and free of AceMQ semantics. Retries, dead lettering, idempotency and telemetry belong to the core; a transport only moves bytes and reports what the broker can do. Keeping the seam this narrow is what allows one engine to sit on top of AMQP 0-9-1 and AMQP 1.0 without either leaking into the other.

Related Packages

Package	Description
org.acemq.amqp.transport.rabbitmq	AMQP 0-9-1 transport backed by the RabbitMQ Java client.

Class	Description
Acknowledger	Settles one delivery.
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.
DeliveryListener	Receives deliveries from a subscription.
InboundDelivery	A message handed up from the broker, still encoded.
OutboundMessage	A message on its way to the broker, already encoded.
OutboundMessage.Builder	Builds OutboundMessage instances.
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.
Subscription	A live consumer registration.
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.