Index
All Classes and Interfaces|All Packages
A
- AceListener - Annotation Interface in org.acemq.spring.boot
-
Consumes a queue with the annotated method.
- aceListenerAnnotationBeanPostProcessor(ObjectProvider<AceListenerRegistry>, AceMqProperties) - Static method in class org.acemq.spring.boot.AceMqAutoConfiguration
-
The post-processor that finds
AceListenermethods. - AceListenerAnnotationBeanPostProcessor - Class in org.acemq.spring.boot
-
Finds
AceListenermethods on every bean and registers them. - AceListenerAnnotationBeanPostProcessor(ObjectProvider<AceListenerRegistry>, AceMqProperties.Listener) - Constructor for class org.acemq.spring.boot.AceListenerAnnotationBeanPostProcessor
- AceListenerEndpoint - Class in org.acemq.spring.boot
-
One
AceListenermethod, resolved: which queue, how many consumers, what the payload type is, and how to call it. - aceListenerRegistry(AceMq, AceMqProperties) - Method in class org.acemq.spring.boot.AceMqAutoConfiguration
-
The listener registry, which starts and stops the annotated methods.
- AceListenerRegistry - Class in org.acemq.spring.boot
-
Starts and stops the
AceListenermethods, and hands out the running consumers. - AceListenerRegistry(AceMq, AceMqProperties.Listener) - Constructor for class org.acemq.spring.boot.AceListenerRegistry
- AceListenerRegistry(AceMq, AceMqProperties.Listener, Topology, ApplyMode) - Constructor for class org.acemq.spring.boot.AceListenerRegistry
- aceMq(ConnectionConfig, Telemetry, Codec) - Method in class org.acemq.spring.boot.AceMqAutoConfiguration
-
The connection.
- AceMqAutoConfiguration - Class in org.acemq.spring.boot
-
Wires AceMQ from
acemq.*. - AceMqAutoConfiguration() - Constructor for class org.acemq.spring.boot.AceMqAutoConfiguration
- AceMqAutoConfiguration.Micrometer - Class in org.acemq.spring.boot
-
Telemetry through Micrometer, which is how the library's metrics reach whatever the application already exports to.
- AceMqAutoConfiguration.NoMicrometer - Class in org.acemq.spring.boot
-
Telemetry without Micrometer: whatever the library can detect, which finds OpenTelemetry if it is there and is otherwise a no-op.
- aceMqCodec(AceMqProperties) - Method in class org.acemq.spring.boot.AceMqAutoConfiguration
-
The default codec.
- aceMqConnectionConfig(AceMqProperties, AceMqConnectionDetails, Environment) - Method in class org.acemq.spring.boot.AceMqAutoConfiguration
-
The connection configuration, separately from the connection, so an application can see and override it without taking over connecting.
- aceMqConnectionDetails(AceMqProperties) - Method in class org.acemq.spring.boot.AceMqAutoConfiguration
-
Where the broker is, read from
acemq.*. - AceMqConnectionDetails - Interface in org.acemq.spring.boot
-
Where the broker is: the part of
acemq.*that a service connection can supply. - AceMqConnections - Class in org.acemq.spring.boot
-
Turns
AceMqPropertiesinto aConnectionConfig. - aceMqEndpoint(AceListenerRegistry) - Method in class org.acemq.spring.boot.actuate.AceMqEndpointAutoConfiguration
- AceMqEndpoint - Class in org.acemq.spring.boot.actuate
-
The
acemqactuator endpoint: everyAceListener, its queue, whether it is running, and the counters its consumers keep. - AceMqEndpoint(AceListenerRegistry) - Constructor for class org.acemq.spring.boot.actuate.AceMqEndpoint
- AceMqEndpoint.Counters - Record Class in org.acemq.spring.boot.actuate
-
A running listener's counters, from its consumer group.
- AceMqEndpoint.ListenerDescriptor - Record Class in org.acemq.spring.boot.actuate
-
One listener.
- AceMqEndpoint.ListenersDescriptor - Record Class in org.acemq.spring.boot.actuate
-
Every listener.
- AceMqEndpointAutoConfiguration - Class in org.acemq.spring.boot.actuate
-
Registers the
AceMqEndpointwhen the actuator is on the classpath and the endpoint is exposed. - AceMqEndpointAutoConfiguration() - Constructor for class org.acemq.spring.boot.actuate.AceMqEndpointAutoConfiguration
- AceMqProperties - Class in org.acemq.spring.boot
-
Everything under
acemq.*in an application's configuration. - AceMqProperties() - Constructor for class org.acemq.spring.boot.AceMqProperties
- AceMqProperties.Listener - Class in org.acemq.spring.boot
-
Defaults for every
AceListener, each of which can override them. - AceMqProperties.Listener.MissingQueue - Enum Class in org.acemq.spring.boot
-
What a listener whose queue is missing does at startup.
- AceMqProperties.Listener.Retry - Class in org.acemq.spring.boot
-
The retry ladder applied to a handler that throws a retryable exception.
- AceMqProperties.Tls - Class in org.acemq.spring.boot
-
TLS.
- AceMqProperties.Tls.Mode - Enum Class in org.acemq.spring.boot
- AceMqProperties.Topology - Class in org.acemq.spring.boot
-
Exchanges, queues and bindings the application expects to exist.
- AceMqProperties.Topology.Apply - Enum Class in org.acemq.spring.boot
- AceMqProperties.Topology.Binding - Class in org.acemq.spring.boot
- AceMqProperties.Topology.Exchange - Class in org.acemq.spring.boot
- AceMqProperties.Topology.Queue - Class in org.acemq.spring.boot
- AceMqProperties.Topology.Queue.Kind - Enum Class in org.acemq.spring.boot
- aceMqTelemetry(AceMqProperties) - Method in class org.acemq.spring.boot.AceMqAutoConfiguration.NoMicrometer
- aceMqTelemetry(ObjectProvider<MeterRegistry>, AceMqProperties) - Method in class org.acemq.spring.boot.AceMqAutoConfiguration.Micrometer
- AceMqTopologies - Class in org.acemq.spring.boot
-
Turns declared
acemq.topology.*properties into aTopology. - aceMqTopologyInitializer(AceMq, AceMqProperties) - Method in class org.acemq.spring.boot.AceMqAutoConfiguration
-
Applies the declared topology.
- AceMqTopologyInitializer - Class in org.acemq.spring.boot
-
Applies the declared topology once, at startup.
- AceMqTopologyInitializer(AceMq, Topology, ApplyMode, boolean) - Constructor for class org.acemq.spring.boot.AceMqTopologyInitializer
- AceQueue - Annotation Interface in org.acemq.spring.boot
-
How an
AceListenerdeclares the queue it consumes, throughAceListener.declare(). - acknowledged() - Method in record class org.acemq.spring.boot.actuate.AceMqEndpoint.Counters
-
Returns the value of the
acknowledgedrecord component. - afterPropertiesSet() - Method in class org.acemq.spring.boot.AceMqTopologyInitializer
- arguments() - Element in annotation interface org.acemq.spring.boot.AceQueue
-
Broker arguments as
name=value, asacemq.topology.queues[].arguments, and for classic queues only. - autoStartup() - Element in annotation interface org.acemq.spring.boot.AceListener
-
Whether to start with the application context.
- autoStartup() - Method in record class org.acemq.spring.boot.actuate.AceMqEndpoint.ListenerDescriptor
-
Returns the value of the
autoStartuprecord component.
B
- bean() - Method in record class org.acemq.spring.boot.actuate.AceMqEndpoint.ListenerDescriptor
-
Returns the value of the
beanrecord component. - beanName() - Method in class org.acemq.spring.boot.AceListenerEndpoint
-
The name of the bean that declares the method.
- Binding() - Constructor for class org.acemq.spring.boot.AceMqProperties.Topology.Binding
C
- CLASSIC - Enum constant in enum class org.acemq.spring.boot.AceMqProperties.Topology.Queue.Kind
- concurrency() - Element in annotation interface org.acemq.spring.boot.AceListener
-
Consumers on this queue. -1 takes
acemq.listener.concurrency. - concurrency() - Method in class org.acemq.spring.boot.AceListenerEndpoint
- concurrency() - Method in record class org.acemq.spring.boot.actuate.AceMqEndpoint.ListenerDescriptor
-
Returns the value of the
concurrencyrecord component. - counters() - Method in record class org.acemq.spring.boot.actuate.AceMqEndpoint.ListenerDescriptor
-
Returns the value of the
countersrecord component. - Counters(long, long, long, long) - Constructor for record class org.acemq.spring.boot.actuate.AceMqEndpoint.Counters
-
Creates an instance of a
Countersrecord class. - CREATE_ONLY - Enum constant in enum class org.acemq.spring.boot.AceMqProperties.Topology.Apply
D
- deadLetter() - Element in annotation interface org.acemq.spring.boot.AceQueue
-
Dead-letter what the broker rejects, as
acemq.topology.queues[].dead-letter. - declaration() - Method in class org.acemq.spring.boot.AceListenerEndpoint
-
What the listener declares before it starts, from
AceListener.declare(): the queue, and its dead-letter queues when it asked for them. - declare() - Element in annotation interface org.acemq.spring.boot.AceListener
-
Declare the queue before consuming it:
declare = @AceQueuefor a durable quorum queue, ordeclare = @AceQueue(type = Kind.CLASSIC, ...). - details(AceMqProperties) - Static method in class org.acemq.spring.boot.AceMqConnections
-
The connection details
acemq.*describes, used when no service connection supplies others. - DISABLED - Enum constant in enum class org.acemq.spring.boot.AceMqProperties.Tls.Mode
-
Plain AMQP.
- DRY_RUN - Enum constant in enum class org.acemq.spring.boot.AceMqProperties.Topology.Apply
E
- endpoints() - Method in class org.acemq.spring.boot.AceListenerRegistry
-
Every registered listener, started or not.
- equals(Object) - Method in record class org.acemq.spring.boot.actuate.AceMqEndpoint.Counters
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class org.acemq.spring.boot.actuate.AceMqEndpoint.ListenerDescriptor
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class org.acemq.spring.boot.actuate.AceMqEndpoint.ListenersDescriptor
-
Indicates whether some other object is "equal to" this one.
- Exchange() - Constructor for class org.acemq.spring.boot.AceMqProperties.Topology.Exchange
F
- FAIL - Enum constant in enum class org.acemq.spring.boot.AceMqProperties.Listener.MissingQueue
-
Fail the application's startup.
- from(AceMqProperties) - Static method in class org.acemq.spring.boot.AceMqConnections
-
Builds the connection configuration.
- from(AceMqProperties.Topology) - Static method in class org.acemq.spring.boot.AceMqTopologies
-
Builds the topology.
- from(AceMqProperties, AceMqConnectionDetails) - Static method in class org.acemq.spring.boot.AceMqConnections
-
Builds the connection configuration with the broker's address taken from connection details, which is how Docker Compose and Testcontainers supply it.
G
- get(String) - Method in class org.acemq.spring.boot.AceListenerRegistry
-
The running consumer group for a listener id, for scaling, pausing or reading counters.
- getApply() - Method in class org.acemq.spring.boot.AceMqProperties.Topology
- getArguments() - Method in class org.acemq.spring.boot.AceMqProperties.Topology.Queue
- getBindings() - Method in class org.acemq.spring.boot.AceMqProperties.Topology
- getBlockedTimeout() - Method in class org.acemq.spring.boot.AceMqProperties
- getClientName() - Method in class org.acemq.spring.boot.AceMqProperties
- getConcurrency() - Method in class org.acemq.spring.boot.AceMqProperties.Listener
- getConfirmTimeout() - Method in class org.acemq.spring.boot.AceMqProperties
- getConnectionTimeout() - Method in class org.acemq.spring.boot.AceMqProperties
- getExchange() - Method in class org.acemq.spring.boot.AceMqProperties.Topology.Binding
- getExchanges() - Method in class org.acemq.spring.boot.AceMqProperties.Topology
- getFormat() - Method in class org.acemq.spring.boot.AceMqProperties
- getGiveUpAfter() - Method in class org.acemq.spring.boot.AceMqProperties.Listener.Retry
- getInitialDelay() - Method in class org.acemq.spring.boot.AceMqProperties.Listener.Retry
- getJitter() - Method in class org.acemq.spring.boot.AceMqProperties.Listener.Retry
- getKeystore() - Method in class org.acemq.spring.boot.AceMqProperties.Tls
- getKeystorePassword() - Method in class org.acemq.spring.boot.AceMqProperties.Tls
- getListener() - Method in class org.acemq.spring.boot.AceMqProperties
- getMaxAttempts() - Method in class org.acemq.spring.boot.AceMqProperties.Listener.Retry
- getMaxDelay() - Method in class org.acemq.spring.boot.AceMqProperties.Listener.Retry
- getMaxOutstandingPublishes() - Method in class org.acemq.spring.boot.AceMqProperties
- getMissingQueue() - Method in class org.acemq.spring.boot.AceMqProperties.Listener
- getMode() - Method in class org.acemq.spring.boot.AceMqProperties.Tls
- getMultiplier() - Method in class org.acemq.spring.boot.AceMqProperties.Listener.Retry
- getName() - Method in class org.acemq.spring.boot.AceMqProperties.Topology.Exchange
- getName() - Method in class org.acemq.spring.boot.AceMqProperties.Topology.Queue
- getPassword() - Method in interface org.acemq.spring.boot.AceMqConnectionDetails
- getPassword() - Method in class org.acemq.spring.boot.AceMqProperties
- getPhase() - Method in class org.acemq.spring.boot.AceListenerRegistry
-
The default phase, which is
Integer.MAX_VALUEand stops first. - getPrefetch() - Method in class org.acemq.spring.boot.AceMqProperties.Listener
- getQueue() - Method in class org.acemq.spring.boot.AceMqProperties.Topology.Binding
- getQueues() - Method in class org.acemq.spring.boot.AceMqProperties.Topology
- getRetry() - Method in class org.acemq.spring.boot.AceMqProperties.Listener
- getRoutingKey() - Method in class org.acemq.spring.boot.AceMqProperties.Topology.Binding
- getShutdownTimeout() - Method in class org.acemq.spring.boot.AceMqProperties.Listener
- getTls() - Method in class org.acemq.spring.boot.AceMqProperties
- getTopology() - Method in class org.acemq.spring.boot.AceMqProperties
- getType() - Method in class org.acemq.spring.boot.AceMqProperties.Topology.Exchange
- getType() - Method in class org.acemq.spring.boot.AceMqProperties.Topology.Queue
- getUrl() - Method in interface org.acemq.spring.boot.AceMqConnectionDetails
-
The broker URL, such as
amqp://localhost:5672. - getUrl() - Method in class org.acemq.spring.boot.AceMqProperties
- getUsername() - Method in interface org.acemq.spring.boot.AceMqConnectionDetails
- getUsername() - Method in class org.acemq.spring.boot.AceMqProperties
- getVirtualHost() - Method in interface org.acemq.spring.boot.AceMqConnectionDetails
- getVirtualHost() - Method in class org.acemq.spring.boot.AceMqProperties
H
- hashCode() - Method in record class org.acemq.spring.boot.actuate.AceMqEndpoint.Counters
-
Returns a hash code value for this object.
- hashCode() - Method in record class org.acemq.spring.boot.actuate.AceMqEndpoint.ListenerDescriptor
-
Returns a hash code value for this object.
- hashCode() - Method in record class org.acemq.spring.boot.actuate.AceMqEndpoint.ListenersDescriptor
-
Returns a hash code value for this object.
I
- id() - Element in annotation interface org.acemq.spring.boot.AceListener
-
A name for this listener, used in logs and by
AceListenerRegistry.get(String). - id() - Method in class org.acemq.spring.boot.AceListenerEndpoint
- inFlight() - Method in record class org.acemq.spring.boot.actuate.AceMqEndpoint.Counters
-
Returns the value of the
inFlightrecord component. - INSECURE - Enum constant in enum class org.acemq.spring.boot.AceMqProperties.Tls.Mode
-
TLS, nothing verified.
- isAllowDevelopmentCertificates() - Method in class org.acemq.spring.boot.AceMqProperties.Tls
- isAutoStartup() - Method in class org.acemq.spring.boot.AceListenerEndpoint
- isAutoStartup() - Method in class org.acemq.spring.boot.AceListenerRegistry
- isAutoStartup() - Method in class org.acemq.spring.boot.AceMqProperties.Listener
- isDeadLetter() - Method in class org.acemq.spring.boot.AceMqProperties.Topology.Queue
- isEmpty() - Method in class org.acemq.spring.boot.AceMqProperties.Topology
-
Nothing declared, nothing to apply.
- isEnabled() - Method in class org.acemq.spring.boot.AceMqProperties
- isEnabled() - Method in class org.acemq.spring.boot.AceMqProperties.Listener.Retry
- isFailOnDrift() - Method in class org.acemq.spring.boot.AceMqProperties.Topology
- isPublisherConfirms() - Method in class org.acemq.spring.boot.AceMqProperties
- isRequeueOnFailure() - Method in class org.acemq.spring.boot.AceMqProperties.Listener
- isRunning() - Method in class org.acemq.spring.boot.AceListenerRegistry
L
- listener(String) - Method in class org.acemq.spring.boot.actuate.AceMqEndpoint
- Listener() - Constructor for class org.acemq.spring.boot.AceMqProperties.Listener
- ListenerDescriptor(String, String, String, boolean, int, int, AceMqEndpoint.Counters) - Constructor for record class org.acemq.spring.boot.actuate.AceMqEndpoint.ListenerDescriptor
-
Creates an instance of a
ListenerDescriptorrecord class. - listeners() - Method in class org.acemq.spring.boot.actuate.AceMqEndpoint
- listeners() - Method in record class org.acemq.spring.boot.actuate.AceMqEndpoint.ListenersDescriptor
-
Returns the value of the
listenersrecord component. - ListenersDescriptor(Map<String, AceMqEndpoint.ListenerDescriptor>) - Constructor for record class org.acemq.spring.boot.actuate.AceMqEndpoint.ListenersDescriptor
-
Creates an instance of a
ListenersDescriptorrecord class.
M
- method() - Method in class org.acemq.spring.boot.AceListenerEndpoint
-
The annotated method.
- Micrometer() - Constructor for class org.acemq.spring.boot.AceMqAutoConfiguration.Micrometer
- mode(AceMqProperties.Topology.Apply) - Static method in class org.acemq.spring.boot.AceMqTopologies
-
Maps the property to the library's apply mode.
N
- NoMicrometer() - Constructor for class org.acemq.spring.boot.AceMqAutoConfiguration.NoMicrometer
O
- org.acemq.spring.boot - package org.acemq.spring.boot
-
Spring Boot auto-configuration for acemq-java-amqp.
- org.acemq.spring.boot.actuate - package org.acemq.spring.boot.actuate
- org.acemq.spring.boot.docker - package org.acemq.spring.boot.docker
- org.acemq.spring.boot.testcontainers - package org.acemq.spring.boot.testcontainers
P
- payloadType() - Method in class org.acemq.spring.boot.AceListenerEndpoint
-
The type messages are decoded into, which is the parameter type or its Message type.
- postProcessAfterInitialization(Object, String) - Method in class org.acemq.spring.boot.AceListenerAnnotationBeanPostProcessor
- prefetch() - Element in annotation interface org.acemq.spring.boot.AceListener
-
Unacknowledged messages allowed at once. -1 takes
acemq.listener.prefetch. - prefetch() - Method in class org.acemq.spring.boot.AceListenerEndpoint
- prefetch() - Method in record class org.acemq.spring.boot.actuate.AceMqEndpoint.ListenerDescriptor
-
Returns the value of the
prefetchrecord component.
Q
- queue() - Element in annotation interface org.acemq.spring.boot.AceListener
-
The queue to consume.
- queue() - Method in class org.acemq.spring.boot.AceListenerEndpoint
- queue() - Method in record class org.acemq.spring.boot.actuate.AceMqEndpoint.ListenerDescriptor
-
Returns the value of the
queuerecord component. - Queue() - Constructor for class org.acemq.spring.boot.AceMqProperties.Topology.Queue
- QUORUM - Enum constant in enum class org.acemq.spring.boot.AceMqProperties.Topology.Queue.Kind
R
- register(AceListenerEndpoint) - Method in class org.acemq.spring.boot.AceListenerRegistry
-
Registers an endpoint.
- rejected() - Method in record class org.acemq.spring.boot.actuate.AceMqEndpoint.Counters
-
Returns the value of the
rejectedrecord component. - REQUIRED - Enum constant in enum class org.acemq.spring.boot.AceMqProperties.Tls.Mode
-
TLS, chain and hostname verified.
- retried() - Method in record class org.acemq.spring.boot.actuate.AceMqEndpoint.Counters
-
Returns the value of the
retriedrecord component. - Retry() - Constructor for class org.acemq.spring.boot.AceMqProperties.Listener.Retry
- running() - Method in class org.acemq.spring.boot.AceListenerRegistry
-
The running groups by listener id.
S
- setAllowDevelopmentCertificates(boolean) - Method in class org.acemq.spring.boot.AceMqProperties.Tls
- setApply(AceMqProperties.Topology.Apply) - Method in class org.acemq.spring.boot.AceMqProperties.Topology
- setArguments(Map<String, Object>) - Method in class org.acemq.spring.boot.AceMqProperties.Topology.Queue
- setAutoStartup(boolean) - Method in class org.acemq.spring.boot.AceMqProperties.Listener
- setBindings(List<AceMqProperties.Topology.Binding>) - Method in class org.acemq.spring.boot.AceMqProperties.Topology
- setBlockedTimeout(Duration) - Method in class org.acemq.spring.boot.AceMqProperties
- setClientName(String) - Method in class org.acemq.spring.boot.AceMqProperties
- setConcurrency(int) - Method in class org.acemq.spring.boot.AceMqProperties.Listener
- setConfirmTimeout(Duration) - Method in class org.acemq.spring.boot.AceMqProperties
- setConnectionTimeout(Duration) - Method in class org.acemq.spring.boot.AceMqProperties
- setDeadLetter(boolean) - Method in class org.acemq.spring.boot.AceMqProperties.Topology.Queue
- setEmbeddedValueResolver(StringValueResolver) - Method in class org.acemq.spring.boot.AceListenerAnnotationBeanPostProcessor
- setEnabled(boolean) - Method in class org.acemq.spring.boot.AceMqProperties.Listener.Retry
- setEnabled(boolean) - Method in class org.acemq.spring.boot.AceMqProperties
- setExchange(String) - Method in class org.acemq.spring.boot.AceMqProperties.Topology.Binding
- setExchanges(List<AceMqProperties.Topology.Exchange>) - Method in class org.acemq.spring.boot.AceMqProperties.Topology
- setFailOnDrift(boolean) - Method in class org.acemq.spring.boot.AceMqProperties.Topology
- setFormat(String) - Method in class org.acemq.spring.boot.AceMqProperties
- setGiveUpAfter(Duration) - Method in class org.acemq.spring.boot.AceMqProperties.Listener.Retry
- setInitialDelay(Duration) - Method in class org.acemq.spring.boot.AceMqProperties.Listener.Retry
- setJitter(double) - Method in class org.acemq.spring.boot.AceMqProperties.Listener.Retry
- setKeystore(Path) - Method in class org.acemq.spring.boot.AceMqProperties.Tls
- setKeystorePassword(String) - Method in class org.acemq.spring.boot.AceMqProperties.Tls
- setMaxAttempts(int) - Method in class org.acemq.spring.boot.AceMqProperties.Listener.Retry
- setMaxDelay(Duration) - Method in class org.acemq.spring.boot.AceMqProperties.Listener.Retry
- setMaxOutstandingPublishes(int) - Method in class org.acemq.spring.boot.AceMqProperties
- setMissingQueue(AceMqProperties.Listener.MissingQueue) - Method in class org.acemq.spring.boot.AceMqProperties.Listener
- setMode(AceMqProperties.Tls.Mode) - Method in class org.acemq.spring.boot.AceMqProperties.Tls
- setMultiplier(double) - Method in class org.acemq.spring.boot.AceMqProperties.Listener.Retry
- setName(String) - Method in class org.acemq.spring.boot.AceMqProperties.Topology.Exchange
- setName(String) - Method in class org.acemq.spring.boot.AceMqProperties.Topology.Queue
- setPassword(String) - Method in class org.acemq.spring.boot.AceMqProperties
- setPrefetch(int) - Method in class org.acemq.spring.boot.AceMqProperties.Listener
- setPublisherConfirms(boolean) - Method in class org.acemq.spring.boot.AceMqProperties
- setQueue(String) - Method in class org.acemq.spring.boot.AceMqProperties.Topology.Binding
- setQueues(List<AceMqProperties.Topology.Queue>) - Method in class org.acemq.spring.boot.AceMqProperties.Topology
- setRequeueOnFailure(boolean) - Method in class org.acemq.spring.boot.AceMqProperties.Listener
- setRoutingKey(String) - Method in class org.acemq.spring.boot.AceMqProperties.Topology.Binding
- setShutdownTimeout(Duration) - Method in class org.acemq.spring.boot.AceMqProperties.Listener
- setState(String, String) - Method in class org.acemq.spring.boot.actuate.AceMqEndpoint
-
Starts or stops a listener.
- setType(String) - Method in class org.acemq.spring.boot.AceMqProperties.Topology.Exchange
- setType(AceMqProperties.Topology.Queue.Kind) - Method in class org.acemq.spring.boot.AceMqProperties.Topology.Queue
- setUrl(String) - Method in class org.acemq.spring.boot.AceMqProperties
- setUsername(String) - Method in class org.acemq.spring.boot.AceMqProperties
- setVirtualHost(String) - Method in class org.acemq.spring.boot.AceMqProperties
- start() - Method in class org.acemq.spring.boot.AceListenerRegistry
-
Starts every listener with auto-startup on, after declaring the queues they declare and checking that the rest exist.
- start(String) - Method in class org.acemq.spring.boot.AceListenerRegistry
-
Starts one listener: one registered with auto-startup off, one left stopped because its queue was missing, or one stopped with
AceListenerRegistry.stop(String). - state() - Method in record class org.acemq.spring.boot.actuate.AceMqEndpoint.ListenerDescriptor
-
Returns the value of the
staterecord component. - stop() - Method in class org.acemq.spring.boot.AceListenerRegistry
- stop(String) - Method in class org.acemq.spring.boot.AceListenerRegistry
-
Stops one listener: it stops taking messages, waits up to
acemq.listener.shutdown-timeoutfor the ones in flight, and closes.
T
- takesMessage() - Method in class org.acemq.spring.boot.AceListenerEndpoint
-
Whether the method asked for the whole message rather than the payload.
- Tls() - Constructor for class org.acemq.spring.boot.AceMqProperties.Tls
- Topology() - Constructor for class org.acemq.spring.boot.AceMqProperties.Topology
- toString() - Method in class org.acemq.spring.boot.AceListenerEndpoint
- toString() - Method in record class org.acemq.spring.boot.actuate.AceMqEndpoint.Counters
-
Returns a string representation of this record class.
- toString() - Method in record class org.acemq.spring.boot.actuate.AceMqEndpoint.ListenerDescriptor
-
Returns a string representation of this record class.
- toString() - Method in record class org.acemq.spring.boot.actuate.AceMqEndpoint.ListenersDescriptor
-
Returns a string representation of this record class.
- type() - Element in annotation interface org.acemq.spring.boot.AceQueue
-
quorum or classic, as
acemq.topology.queues[].type.
V
- VALIDATE - Enum constant in enum class org.acemq.spring.boot.AceMqProperties.Topology.Apply
- valueOf(String) - Static method in enum class org.acemq.spring.boot.AceMqProperties.Listener.MissingQueue
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class org.acemq.spring.boot.AceMqProperties.Tls.Mode
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class org.acemq.spring.boot.AceMqProperties.Topology.Apply
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class org.acemq.spring.boot.AceMqProperties.Topology.Queue.Kind
-
Returns the enum constant of this class with the specified name.
- values() - Static method in enum class org.acemq.spring.boot.AceMqProperties.Listener.MissingQueue
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class org.acemq.spring.boot.AceMqProperties.Tls.Mode
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class org.acemq.spring.boot.AceMqProperties.Topology.Apply
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class org.acemq.spring.boot.AceMqProperties.Topology.Queue.Kind
-
Returns an array containing the constants of this enum class, in the order they are declared.
W
- WARN - Enum constant in enum class org.acemq.spring.boot.AceMqProperties.Listener.MissingQueue
-
Log a warning and leave the listener stopped; it can be started later.
All Classes and Interfaces|All Packages