Index

A B C D E F G H I L M N O P Q R S T V W 
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 AceListener methods.
AceListenerAnnotationBeanPostProcessor - Class in org.acemq.spring.boot
Finds AceListener methods 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 AceListener method, 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 AceListener methods, 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 AceMqProperties into a ConnectionConfig.
aceMqEndpoint(AceListenerRegistry) - Method in class org.acemq.spring.boot.actuate.AceMqEndpointAutoConfiguration
 
AceMqEndpoint - Class in org.acemq.spring.boot.actuate
The acemq actuator endpoint: every AceListener, 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 AceMqEndpoint when 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 a Topology.
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 AceListener declares the queue it consumes, through AceListener.declare().
acknowledged() - Method in record class org.acemq.spring.boot.actuate.AceMqEndpoint.Counters
Returns the value of the acknowledged record 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, as acemq.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 autoStartup record component.

B

bean() - Method in record class org.acemq.spring.boot.actuate.AceMqEndpoint.ListenerDescriptor
Returns the value of the bean record 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 concurrency record component.
counters() - Method in record class org.acemq.spring.boot.actuate.AceMqEndpoint.ListenerDescriptor
Returns the value of the counters record component.
Counters(long, long, long, long) - Constructor for record class org.acemq.spring.boot.actuate.AceMqEndpoint.Counters
Creates an instance of a Counters record 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 = @AceQueue for a durable quorum queue, or declare = @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_VALUE and 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 inFlight record 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 ListenerDescriptor record 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 listeners record component.
ListenersDescriptor(Map<String, AceMqEndpoint.ListenerDescriptor>) - Constructor for record class org.acemq.spring.boot.actuate.AceMqEndpoint.ListenersDescriptor
Creates an instance of a ListenersDescriptor record 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 prefetch record 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 queue record 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 rejected record 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 retried record 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 state record 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-timeout for 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.
A B C D E F G H I L M N O P Q R S T V W 
All Classes and Interfaces|All Packages