Uses of Class
org.acemq.amqp.core.AceMq

Packages that use AceMq

Package	Description
org.acemq.amqp.actuator	A scrape surface for an application that has no HTTP server of its own.
org.acemq.amqp.core	The protocol-agnostic engine.
org.acemq.amqp.patterns	Distributed messaging patterns as things you configure rather than reimplement.

Uses of AceMq in org.acemq.amqp.actuator

Methods in org.acemq.amqp.actuator that return AceMq

Modifier and Type	Method	Description
@Nullable AceMq	ActuatorOptions.connection()

Methods in org.acemq.amqp.actuator with parameters of type AceMq

Modifier and Type	Method	Description
ActuatorOptions.Builder	ActuatorOptions.Builder.connection(AceMq connection)	The connection /acemq-health reports on and /acemq-info describes.
static AceMqActuator	AceMqActuator.start(AceMq mq)	Starts an actuator on the default port and paths, reporting on one connection.

Uses of AceMq in org.acemq.amqp.core

Methods in org.acemq.amqp.core that return AceMq

Modifier and Type	Method	Description
AceMq	AceMq.bind(String queue, String exchange, String routingKey)	Binds a queue to an exchange.
static AceMq	AceMq.connect(String url)	Connects to a broker, choosing the transport from the URL scheme.
static AceMq	AceMq.connect(String url, @Nullable Telemetry telemetry)	Connects to a broker with an explicit telemetry sink.
static AceMq	AceMq.connect(String url, @Nullable Telemetry telemetry, Codec codec)	Connects to a broker with an explicit telemetry sink and codec.
static AceMq	AceMq.connect(String url, Codec codec)	Connects to a broker, reading and writing payloads with the given codec.
static AceMq	AceMq.connect(ConnectionConfig config)	Connects to a broker with explicit settings.
static AceMq	AceMq.connect(ConnectionConfig config, @Nullable Telemetry telemetry)	Connects with an explicit telemetry sink.
static AceMq	AceMq.connect(ConnectionConfig config, @Nullable Telemetry telemetry, @Nullable Codec codec)	Connects with an explicit telemetry sink and codec.
AceMq	AceMq.declareExchange(String name, String type)	Declares a durable exchange.
AceMq	AceMq.declareQueue(String name)	Declares a durable quorum queue.
AceMq	AceMq.declareQueue(String name, QueueType type, Map<String,Object> arguments)	Declares a queue of a specific type.
AceMq	AceMq.declareStream(String name, @Nullable Duration maxAge, @Nullable Long maxLengthBytes)	Declares a stream: an append-only log that keeps messages until retention removes them.
AceMq	AceMq.declareStream(String name, @Nullable Duration maxAge, @Nullable Long maxLengthBytes, @Nullable Long segmentBytes)	Declares a stream, saying how large each file on disk gets.
AceMq	AceMq.intercept(ConsumeInterceptor interceptor)	Runs something around every handler on this connection.
AceMq	AceMq.intercept(PublishInterceptor interceptor)	Runs something around every publish on this connection.

Uses of AceMq in org.acemq.amqp.patterns

Methods in org.acemq.amqp.patterns with parameters of type AceMq

Modifier and Type	Method	Description
static Scheduler	Scheduler.on(AceMq mq)

Constructors in org.acemq.amqp.patterns with parameters of type AceMq

Modifier	Constructor	Description
	OutboxRelay(AceMq mq, OutboxStore store)
	OutboxRelay(AceMq mq, OutboxStore store, int batchSize, Duration pollInterval, Duration lease)