All Classes and Interfaces
Class
Description
Consumes a queue with the annotated method.
Finds
AceListener methods on every bean and registers them.One
AceListener method, resolved: which queue, how many consumers, what the
payload type is, and how to call it.Starts and stops the
AceListener methods, and hands out the running consumers.Wires AceMQ from
acemq.*.Telemetry through Micrometer, which is how the library's metrics reach whatever the
application already exports to.
Telemetry without Micrometer: whatever the library can detect, which finds
OpenTelemetry if it is there and is otherwise a no-op.
Where the broker is: the part of
acemq.* that a service connection can supply.Turns
AceMqProperties into a ConnectionConfig.The
acemq actuator endpoint: every AceListener, its
queue, whether it is running, and the counters its consumers keep.A running listener's counters, from its consumer group.
One listener.
Every listener.
Registers the
AceMqEndpoint when the actuator is on the classpath and the endpoint
is exposed.Everything under
acemq.* in an application's configuration.Defaults for every
AceListener, each of which can override them.What a listener whose queue is missing does at startup.
The retry ladder applied to a handler that throws a retryable exception.
TLS.
Exchanges, queues and bindings the application expects to exist.
Turns declared
acemq.topology.* properties into a Topology.Applies the declared topology once, at startup.
How an
AceListener declares the queue it consumes, through
AceListener.declare().