Index
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
G
- generateId() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunning
-
Generate the connection id for the connection used by the rule's connection factory.
- generateId() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
-
Generate the connection id for the connection used by the rule's connection factory.
- generateName() - Method in class org.springframework.amqp.core.Base64UrlNamingStrategy
- generateName() - Method in interface org.springframework.amqp.core.NamingStrategy
- generateName() - Method in class org.springframework.amqp.core.UUIDNamingStrategy
- GenericArgumentsConfigurer(BindingBuilder.GenericExchangeRoutingKeyConfigurer, String) - Constructor for class org.springframework.amqp.core.BindingBuilder.GenericArgumentsConfigurer
- get() - Method in class org.springframework.amqp.utils.MapBuilder
- get(Object) - Static method in class org.springframework.amqp.rabbit.connection.SimpleResourceHolder
-
Retrieve a resource for the given key that is bound to the current thread.
- getAckMode() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getAckMode() - Method in interface org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint
-
Override the container factory's
AcknowledgeMode
. - getAcknowledgeMode() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getActiveConsumerCount() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
- getActualName() - Method in class org.springframework.amqp.core.Queue
-
Return the name provided to the constructor or the broker-generated name if that name is an empty String.
- getAdapter(boolean, Object, Method, boolean, RabbitListenerErrorHandler, BatchingStrategy) - Method in interface org.springframework.amqp.rabbit.listener.MethodRabbitListenerEndpoint.AdapterProvider
-
Get an adapter instance.
- getAddress() - Method in class org.springframework.amqp.rabbit.connection.SimpleConnection
- getAddress(RetryContext) - Static method in class org.springframework.amqp.support.SendRetryContextAccessor
-
Retrieve the
Address
from the context. - getAddresses() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- getAddresses() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getAdmin() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getAdminPassword() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunning
-
Return the admin password.
- getAdminPassword() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
-
Return the admin password.
- getAdminUri() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunning
-
Return the admin uri.
- getAdminUri() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
-
Return the admin uri.
- getAdminUser() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunning
-
Return the admin user.
- getAdminUser() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
-
Return the admin user.
- getAdviceChain() - Method in class org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory
- getAdviceChain() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getAfterReceivePostProcessors() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
-
Return configured after receive
MessagePostProcessor
s ornull
. - getAfterReceivePostProcessors() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getAmqpAdmin() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getAmqpMessageConverter() - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
- getAppId() - Method in class org.springframework.amqp.core.MessageProperties
- getAppId() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getApplicationContext() - Method in class org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory
- getApplicationContext() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- getApplicationContext() - Method in class org.springframework.amqp.rabbit.listener.ObservableListenerContainer
- getApplicationEventPublisher() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- getApplicationEventPublisher() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getApplicationId() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getArguments() - Method in class org.springframework.amqp.core.AbstractBuilder
- getArguments() - Method in class org.springframework.amqp.core.AbstractDeclarable
- getArguments() - Method in interface org.springframework.amqp.core.Exchange
-
A map of arguments used to declare the exchange.
- getArguments() - Method in class org.springframework.amqp.rabbit.test.RabbitListenerTestHarness.InvocationData
- getAutoStartup() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getAutoStartup() - Method in interface org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint
-
Override of the default autoStartup property.
- getBackOffExecution() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
- getBatchingStrategy() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getBatchingStrategy() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getBatchingStrategy() - Method in interface org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint
-
Return this endpoint's batching strategy, or null.
- getBatchListener() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getBatchListener() - Method in interface org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint
-
Whether this endpoint is for a batch listener.
- getBean() - Method in class org.springframework.amqp.rabbit.listener.adapter.DelegatingInvocableHandler
- getBean() - Method in class org.springframework.amqp.rabbit.listener.adapter.HandlerAdapter
-
Get the bean from the handler method.
- getBean() - Method in class org.springframework.amqp.rabbit.listener.adapter.InvocationResult
- getBean() - Method in class org.springframework.amqp.rabbit.listener.MethodRabbitListenerEndpoint
- getBeanClass(Element) - Method in class org.springframework.amqp.rabbit.config.DirectExchangeParser
- getBeanClass(Element) - Method in class org.springframework.amqp.rabbit.config.FanoutExchangeParser
- getBeanClass(Element) - Method in class org.springframework.amqp.rabbit.config.HeadersExchangeParser
- getBeanClass(Element) - Method in class org.springframework.amqp.rabbit.config.QueueParser
- getBeanClass(Element) - Method in class org.springframework.amqp.rabbit.config.TopicExchangeParser
- getBeanExpressionContext() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getBeanFactory() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getBeanName() - Method in class org.springframework.amqp.rabbit.AsyncRabbitTemplate
- getBeanName() - Method in class org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory
- getBeanName() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
-
Return a bean name of the component or null if not a bean.
- getBeanName() - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
- getBeanName() - Method in class org.springframework.amqp.rabbit.listener.ObservableListenerContainer
- getBeanName() - Method in interface org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory
-
Return a bean name of the component or null if not a bean.
- getBeanName() - Method in class org.springframework.amqp.rabbit.support.micrometer.RabbitMessageSenderContext
- getBeanName() - Method in class org.springframework.rabbit.stream.micrometer.RabbitStreamMessageSenderContext
- getBeanResolver() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getBindingsFailedException() - Method in class org.springframework.amqp.rabbit.core.BrokerEventListener
-
Return any exception thrown when attempting to bind the queue to the event exchange.
- getBody() - Method in class org.springframework.amqp.core.Message
- getBody() - Method in class org.springframework.amqp.rabbit.support.Delivery
-
Retrieve the message body.
- getBrokerRunning() - Static method in class org.springframework.amqp.rabbit.junit.RabbitAvailableCondition
- getCacheMode() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
- getCacheProperties() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
- getCause() - Method in class org.springframework.amqp.rabbit.connection.PendingConfirm
- getChannel() - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
- getChannel() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
- getChannel() - Method in class org.springframework.amqp.rabbit.listener.DirectReplyToMessageListenerContainer.ChannelHolder
- getChannel(RabbitResourceHolder) - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.ResourceFactory
-
Fetch an appropriate Channel from the given RabbitResourceHolder.
- getChannel(RabbitResourceHolder) - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor
-
Fetch an appropriate Channel from the given RabbitResourceHolder.
- getChannelCacheSize() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
- getChannelHolder() - Method in class org.springframework.amqp.rabbit.listener.DirectReplyToMessageListenerContainer
-
Get the channel holder associated with a direct reply-to consumer; contains a consumer epoch to prevent inappropriate releases.
- getChannelListener() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
-
A composite channel listener to be used by subclasses when creating and closing channels.
- getChannelNumber() - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- getChannelsExecutor() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
-
Determine the executor service used for target channels.
- getCharset() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getClassIdFieldName() - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
- getClassIdFieldName() - Method in class org.springframework.amqp.support.converter.DefaultClassMapper
-
The name of the header that contains the type id.
- getClassLoader() - Method in class org.springframework.amqp.support.converter.AbstractJackson2MessageConverter
- getClassLoader() - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
- getClassMapper() - Method in class org.springframework.amqp.support.converter.AbstractJackson2MessageConverter
- getCloseReason() - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- getCloseTimeout() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- getClusterId() - Method in class org.springframework.amqp.core.MessageProperties
- getClusterId() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getCompressorStream(OutputStream) - Method in class org.springframework.amqp.support.postprocessor.AbstractCompressingPostProcessor
-
Get the stream.
- getCompressorStream(OutputStream) - Method in class org.springframework.amqp.support.postprocessor.DeflaterPostProcessor
- getCompressorStream(OutputStream) - Method in class org.springframework.amqp.support.postprocessor.GZipPostProcessor
- getCompressorStream(OutputStream) - Method in class org.springframework.amqp.support.postprocessor.ZipPostProcessor
- getConcurrency() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
-
The concurrency of this endpoint; Not used by this abstract class; used by subclasses to set the concurrency appropriate for the container type.
- getConcurrency() - Method in interface org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint
- getConfirm() - Method in class org.springframework.amqp.rabbit.RabbitFuture
-
When confirms are enabled contains a
CompletableFuture
for the confirmation. - getConfirmationCode() - Method in exception org.springframework.rabbit.stream.producer.StreamSendException
-
Return the confirmation code, if available.
- getConnection() - Method in class org.springframework.amqp.rabbit.connection.ConnectionBlockedEvent
- getConnection() - Method in class org.springframework.amqp.rabbit.connection.ConnectionUnblockedEvent
- getConnection() - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- getConnection() - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
- getConnection(RabbitResourceHolder) - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.ResourceFactory
-
Fetch an appropriate Connection from the given RabbitResourceHolder.
- getConnection(RabbitResourceHolder) - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor
-
Fetch an appropriate Connection from the given RabbitResourceHolder.
- getConnectionCacheSize() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
- getConnectionFactory() - Method in class org.springframework.amqp.rabbit.AsyncRabbitTemplate
- getConnectionFactory() - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor
- getConnectionFactory() - Method in class org.springframework.amqp.rabbit.core.RabbitGatewaySupport
- getConnectionFactory() - Method in interface org.springframework.amqp.rabbit.core.RabbitOperations
-
Return the connection factory for this operations.
- getConnectionFactory() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunning
-
Get the connection factory used by this rule.
- getConnectionFactory() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
-
Get the connection factory used by this rule.
- getConnectionFactory() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getConnectionFactory() - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
- getConnectionListener() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
-
A composite connection listener to be used by subclasses when creating and closing connections.
- getConnectionNameStrategy() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- getConsumeDelay() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Get the consumeDelay - a time to wait before consuming in ms.
- getConsumer() - Method in class org.springframework.amqp.rabbit.listener.AsyncConsumerStartedEvent
- getConsumer() - Method in class org.springframework.amqp.rabbit.listener.AsyncConsumerStoppedEvent
- getConsumerArguments() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Return the consumer arguments.
- getConsumerChannel() - Static method in class org.springframework.amqp.rabbit.connection.ConsumerChannelRegistry
-
See registerConsumerChannel.
- getConsumerChannel(ConnectionFactory) - Static method in class org.springframework.amqp.rabbit.connection.ConsumerChannelRegistry
-
See registerConsumerChannel.
- getConsumerCount() - Method in class org.springframework.amqp.core.QueueInformation
- getConsumerEpoch() - Method in class org.springframework.amqp.rabbit.listener.DirectReplyToMessageListenerContainer.ChannelHolder
- getConsumerQueue() - Method in class org.springframework.amqp.core.MessageProperties
- getConsumerQueue() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getConsumerTag() - Method in class org.springframework.amqp.core.MessageProperties
- getConsumerTag() - Method in class org.springframework.amqp.rabbit.listener.ConsumeOkEvent
-
Obtain the consumer tag assigned to the consumer.
- getConsumerTag() - Method in class org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer.SimpleConsumer
- getConsumerTag() - Method in class org.springframework.amqp.rabbit.support.Delivery
-
Retrieve the consumer tag.
- getConsumerTag() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getConsumerTags() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
- getConsumerTagStrategy() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Return the consumer tag strategy to use.
- getContentClassIdFieldName() - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
- getContentEncoding() - Method in class org.springframework.amqp.core.MessageProperties
- getContentEncoding() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getContentEncoding() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getContentLength() - Method in class org.springframework.amqp.core.MessageProperties
- getContentLength() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getContentType() - Method in class org.springframework.amqp.core.MessageProperties
- getContentType() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getContentType() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getContext() - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
-
Return the stream
MessageHandler.Context
for the message. - getContextStopped() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- getContextualName(RabbitMessageReceiverContext) - Method in class org.springframework.amqp.rabbit.support.micrometer.RabbitListenerObservation.DefaultRabbitListenerObservationConvention
- getContextualName(RabbitMessageReceiverContext) - Method in class org.springframework.rabbit.stream.micrometer.RabbitStreamMessageReceiverContext.DefaultRabbitListenerObservationConvention
- getContextualName(RabbitMessageSenderContext) - Method in class org.springframework.amqp.rabbit.support.micrometer.RabbitTemplateObservation.DefaultRabbitTemplateObservationConvention
- getContextualName(RabbitStreamMessageReceiverContext) - Method in class org.springframework.rabbit.stream.micrometer.RabbitStreamListenerObservation.DefaultRabbitStreamListenerObservationConvention
- getContextualName(RabbitStreamMessageSenderContext) - Method in class org.springframework.rabbit.stream.micrometer.RabbitStreamTemplateObservation.DefaultRabbitStreamTemplateObservationConvention
- getConverterForContentType(String) - Method in class org.springframework.amqp.support.converter.ContentTypeDelegatingMessageConverter
- getCorrelationData() - Method in class org.springframework.amqp.rabbit.connection.PendingConfirm
-
The correlation data supplied by the client when sending the message corresponding to this confirmation.
- getCorrelationId() - Method in class org.springframework.amqp.core.MessageProperties
-
Get the correlation id.
- getCorrelationId() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getCount() - Method in class org.springframework.amqp.rabbit.support.ActiveObjectCounter
- getCreationTime() - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
-
See
Properties.getCreationTime()
. - getCustomMethodArgumentResolvers() - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistrar
-
Return the list of
HandlerMethodArgumentResolver
. - getDeclarable() - Method in class org.springframework.amqp.rabbit.core.DeclarationExceptionEvent
- getDeclarables() - Method in class org.springframework.amqp.core.Declarables
- getDeclarablesByType(Class<? extends T>) - Method in class org.springframework.amqp.core.Declarables
-
Return the elements that are instances of the provided class.
- getDeclaringAdmins() - Method in class org.springframework.amqp.core.AbstractDeclarable
- getDeclaringAdmins() - Method in interface org.springframework.amqp.core.Declarable
-
The collection of
AmqpAdmin
s that should declare this object; if empty, all admins should declare. - getDecompressorStream(InputStream) - Method in class org.springframework.amqp.support.postprocessor.AbstractDecompressingPostProcessor
-
Get the stream.
- getDecompressorStream(InputStream) - Method in class org.springframework.amqp.support.postprocessor.GUnzipPostProcessor
- getDecompressorStream(InputStream) - Method in class org.springframework.amqp.support.postprocessor.InflaterPostProcessor
- getDecompressorStream(InputStream) - Method in class org.springframework.amqp.support.postprocessor.UnzipPostProcessor
- getDefaultCharset() - Method in class org.springframework.amqp.support.converter.AbstractJackson2MessageConverter
- getDefaultConsumer() - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- getDefaultHostName() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- getDefaultListenerMethod() - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter
- getDefaultReceiveQueue() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
-
Return the configured default receive queue.
- getDefaultRequeueRejected() - Method in class org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory
-
Return the defaultRequeueRejected.
- getDelayLong() - Method in class org.springframework.amqp.core.MessageProperties
-
Get the x-delay header long value.
- getDelegate() - Method in interface org.springframework.amqp.rabbit.connection.Connection
-
Return the underlying RabbitMQ connection.
- getDelegate() - Method in interface org.springframework.amqp.rabbit.connection.PublisherCallbackChannel
-
Use this to invoke methods on the underlying rabbit client
Channel
that are not supported by this implementation. - getDelegate() - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- getDelegate() - Method in class org.springframework.amqp.rabbit.connection.SimpleConnection
- getDelegate() - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter
- getDelegate(String) - Method in class org.springframework.amqp.rabbit.test.RabbitListenerTestHarness
-
Get the actual listener object (not the spy).
- getDelegates() - Method in class org.springframework.amqp.support.converter.ContentTypeDelegatingMessageConverter
- getDeliveryMode() - Method in class org.springframework.amqp.core.MessageProperties
- getDeliveryMode() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getDeliveryMode() - Method in class org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer
- getDeliveryMode() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getDeliveryTag() - Method in class org.springframework.amqp.core.MessageProperties
- getDeliveryTag() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getDestination() - Method in class org.springframework.amqp.core.Binding
- getDestination() - Method in class org.springframework.amqp.rabbit.support.micrometer.RabbitMessageSenderContext
-
Return the destination -
exchange/routingKey
. - getDestination() - Method in class org.springframework.rabbit.stream.micrometer.RabbitStreamMessageSenderContext
-
Return the destination -
exchange/routingKey
. - getDestinationType() - Method in class org.springframework.amqp.core.Binding
- getEncoder() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getEncoding() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
-
The encoding used when converting between byte arrays and Strings in message properties.
- getEncoding() - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener
-
The encoding to use when inter-converting between byte arrays and Strings in message properties.
- getEncoding() - Method in class org.springframework.amqp.support.postprocessor.AbstractCompressingPostProcessor
-
Get the encoding.
- getEncoding() - Method in class org.springframework.amqp.support.postprocessor.AbstractDecompressingPostProcessor
-
Get the encoding.
- getEncoding() - Method in class org.springframework.amqp.support.postprocessor.DeflaterPostProcessor
- getEncoding() - Method in class org.springframework.amqp.support.postprocessor.GUnzipPostProcessor
- getEncoding() - Method in class org.springframework.amqp.support.postprocessor.GZipPostProcessor
- getEncoding() - Method in class org.springframework.amqp.support.postprocessor.InflaterPostProcessor
- getEncoding() - Method in class org.springframework.amqp.support.postprocessor.UnzipPostProcessor
- getEncoding() - Method in class org.springframework.amqp.support.postprocessor.ZipPostProcessor
- getEndpointDescription() - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerEndpoint
- getEndpointDescription() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getEndpointDescription() - Method in class org.springframework.amqp.rabbit.listener.MethodRabbitListenerEndpoint
- getEndpointRegistry() - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistrar
- getEnvelope() - Method in class org.springframework.amqp.rabbit.support.Delivery
-
Retrieve the message envelope.
- getErrorRoutingKeyPrefix() - Method in class org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer
- getEvent() - Method in class org.springframework.amqp.rabbit.log4j2.AmqpAppender.Event
- getEvent() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender.Event
- getEventProperties() - Method in class org.springframework.amqp.rabbit.core.BrokerEvent
-
Properties of the event
MessageProperties.getHeaders()
. - getEventType() - Method in class org.springframework.amqp.rabbit.core.BrokerEvent
-
The event type (
MessageProperties.getReceivedRoutingKey()
). - getException() - Method in class org.springframework.amqp.support.converter.RemoteInvocationResult
-
Return the exception thrown by an unsuccessful invocation of the target method, if any.
- getExceptions() - Method in class org.springframework.amqp.rabbit.test.mockito.LambdaAnswer
-
Return the exceptions thrown, if any.
- getExceptions() - Method in class org.springframework.amqp.rabbit.test.mockito.LatchCountDownAndCallRealMethodAnswer
-
Return the exceptions thrown.
- getExceptionStrategy() - Method in class org.springframework.amqp.rabbit.listener.ConditionalRejectingErrorHandler
-
Return the exception strategy.
- getExchange() - Method in exception org.springframework.amqp.core.AmqpMessageReturnedException
- getExchange() - Method in class org.springframework.amqp.core.Binding
- getExchange() - Method in class org.springframework.amqp.core.ReturnedMessage
-
Get the exchange.
- getExchange() - Method in class org.springframework.amqp.rabbit.batch.MessageBatch
- getExchange() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- getExchange() - Method in class org.springframework.amqp.rabbit.support.micrometer.RabbitMessageSenderContext
-
Return the exchange.
- getExchangeName() - Method in class org.springframework.amqp.core.Address
- getExchangeName() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getExchangeType() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getExclusiveConsumerExceptionLogger() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getExecutorService() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- getExpiration() - Method in class org.springframework.amqp.core.MessageProperties
-
Get the message expiration.
- getExpiration() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getExpressionString() - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getFailedDeclarationRetryInterval() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getFailedMessage() - Method in exception org.springframework.amqp.rabbit.core.AmqpNackReceivedException
-
Return the failed message.
- getFailedMessage() - Method in exception org.springframework.amqp.rabbit.support.ListenerExecutionFailedException
- getFailedMessages() - Method in exception org.springframework.amqp.rabbit.support.ListenerExecutionFailedException
- getFuture() - Method in class org.springframework.amqp.rabbit.connection.CorrelationData
-
Return a future to check the success/failure of the publish operation.
- getGroup() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getGroup() - Method in interface org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint
- getGroupId() - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
-
See
Properties.getGroupId()
. - getGroupSequence() - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
-
See
Properties.getGroupSequence()
. - getHandlerAdapter() - Method in class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter
- getHandlerForPayload(Class<? extends Object>) - Method in class org.springframework.amqp.rabbit.listener.adapter.DelegatingInvocableHandler
- getHeader(String) - Method in class org.springframework.amqp.core.MessageProperties
-
Typed getter for a header.
- getHeaderMapper() - Method in class org.springframework.amqp.support.converter.MessagingMessageConverter
- getHeaders() - Method in class org.springframework.amqp.core.MessageProperties
- getHost() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- getHost() - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory
- getHost() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactory
- getHost() - Method in class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
- getHost() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getHostName() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunning
-
Return the port.
- getHostName() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
-
Return the port.
- getId() - Method in class org.springframework.amqp.rabbit.connection.CorrelationData
-
Return the id.
- getId() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getId() - Method in interface org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint
- getIdClassMapping() - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
- getIdleEventInterval() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getIdleTime() - Method in class org.springframework.amqp.rabbit.listener.ListenerContainerIdleEvent
-
How long the container has been idle.
- getInferredArgumentType() - Method in class org.springframework.amqp.core.MessageProperties
-
The inferred target argument type when using a method-level
@RabbitListener
. - getInferredType(MessageProperties) - Method in class org.springframework.amqp.support.converter.DefaultJackson2JavaTypeMapper
- getInferredType(MessageProperties) - Method in interface org.springframework.amqp.support.converter.Jackson2JavaTypeMapper
-
Return the inferred type, if the type precedence is inferred and the header is present.
- getInvocationResultFor(Object, Object) - Method in class org.springframework.amqp.rabbit.listener.adapter.DelegatingInvocableHandler
- getInvocationResultFor(Object, Object) - Method in class org.springframework.amqp.rabbit.listener.adapter.HandlerAdapter
-
Build an
InvocationResult
for the result and inbound payload. - getJavaLangErrorHandler() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getJavaTypeMapper() - Method in class org.springframework.amqp.support.converter.AbstractJackson2MessageConverter
- getKey(Message) - Method in interface org.springframework.amqp.rabbit.retry.MessageKeyGenerator
-
Generate a unique key for the message that is repeatable on redelivery.
- getKeyClassIdFieldName() - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
- getKeyStore() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
- getKeyStore() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getKeyStoreAlgorithm() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
- getKeyStorePassphrase() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
- getKeyStorePassphrase() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getKeyStoreResource() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
- getKeyStoreType() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
-
Get the key store type - this defaults to PKCS12 if not overridden by
RabbitConnectionFactoryBean.setSslPropertiesLocation(Resource)
orRabbitConnectionFactoryBean.setKeyStoreType(java.lang.String)
. - getKeyStoreType() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getLambdaAnswerFor(String, boolean, LambdaAnswer.ValueToReturn<T>) - Method in class org.springframework.amqp.rabbit.test.RabbitListenerTestHarness
-
Return a
LambdaAnswer
that is properly configured to invoke the listener. - getLastDeclarationExceptionEvent() - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
- getLastReceive() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Get the time the last message was received - initialized to container start time.
- getLatch() - Method in class org.springframework.amqp.rabbit.test.mockito.LatchCountDownAndCallRealMethodAnswer
- getLatchAnswerFor(String, int) - Method in class org.springframework.amqp.rabbit.test.RabbitListenerTestHarness
-
Return a
LatchCountDownAndCallRealMethodAnswer
that is properly configured to invoke the listener. - getLevel() - Method in class org.springframework.amqp.support.postprocessor.AbstractDeflaterPostProcessor
-
Get the deflater compression level.
- getListenerContainer(String) - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry
-
Return the
MessageListenerContainer
with the specified id ornull
if no such container exists. - getListenerContainerIds() - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry
-
Return the ids of the managed
MessageListenerContainer
instance(s). - getListenerContainers() - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry
- getListenerId() - Method in class org.springframework.amqp.rabbit.listener.ListenerContainerIdleEvent
-
The id of the listener (if
@RabbitListener
) or the container bean name. - getListenerId() - Method in class org.springframework.amqp.rabbit.listener.ObservableListenerContainer
-
The 'id' attribute of the listener.
- getListenerId() - Method in class org.springframework.amqp.rabbit.support.micrometer.RabbitMessageReceiverContext
- getListenerId() - Method in class org.springframework.rabbit.stream.micrometer.RabbitStreamMessageReceiverContext
- getListenerMethodName(Message, Object) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter
-
Determine the name of the listener method that will handle the given message.
- getLocalAddress() - Method in class org.springframework.amqp.rabbit.connection.SimpleConnection
- getLocalPort() - Method in interface org.springframework.amqp.rabbit.connection.Connection
- getLocalPort() - Method in class org.springframework.amqp.rabbit.connection.SimpleConnection
- getLowCardinalityKeyValues(RabbitMessageReceiverContext) - Method in class org.springframework.amqp.rabbit.support.micrometer.RabbitListenerObservation.DefaultRabbitListenerObservationConvention
- getLowCardinalityKeyValues(RabbitMessageReceiverContext) - Method in class org.springframework.rabbit.stream.micrometer.RabbitStreamMessageReceiverContext.DefaultRabbitListenerObservationConvention
- getLowCardinalityKeyValues(RabbitMessageSenderContext) - Method in class org.springframework.amqp.rabbit.support.micrometer.RabbitTemplateObservation.DefaultRabbitTemplateObservationConvention
- getLowCardinalityKeyValues(RabbitStreamMessageReceiverContext) - Method in class org.springframework.rabbit.stream.micrometer.RabbitStreamListenerObservation.DefaultRabbitStreamListenerObservationConvention
- getLowCardinalityKeyValues(RabbitStreamMessageSenderContext) - Method in class org.springframework.rabbit.stream.micrometer.RabbitStreamTemplateObservation.DefaultRabbitStreamTemplateObservationConvention
- getManualDeclarableSet() - Method in interface org.springframework.amqp.core.AmqpAdmin
-
Return the manually declared AMQP objects.
- getManualDeclarableSet() - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
- getMaxFrame(ConnectionFactory) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils
-
Return the negotiated frame_max.
- getMaxSenderRetries() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getMessage() - Method in class org.springframework.amqp.core.ReturnedMessage
-
Get the message.
- getMessage() - Method in class org.springframework.amqp.rabbit.batch.MessageBatch
- getMessage(RetryContext) - Static method in class org.springframework.amqp.support.SendRetryContextAccessor
-
Retrieve the
Message
from the context. - getMessageAckListener() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getMessageConverter() - Method in class org.springframework.amqp.rabbit.AsyncRabbitTemplate
- getMessageConverter() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
-
Return the message converter for this template.
- getMessageConverter() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getMessageConverter() - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener
-
Return the converter that will convert incoming Rabbit messages to listener method arguments, and objects returned from listener methods back to Rabbit messages.
- getMessageConverter() - Method in interface org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint
-
Used by the container factory to check if this endpoint supports the preferred way for a container factory to pass a message converter to the endpoint's adapter.
- getMessageCount() - Method in class org.springframework.amqp.core.MessageProperties
-
Return the server's most recent estimate of the number of messages remaining on the queue.
- getMessageCount() - Method in class org.springframework.amqp.core.QueueInformation
- getMessageCount() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getMessageHandlerMethodFactory() - Method in class org.springframework.amqp.rabbit.listener.MethodRabbitListenerEndpoint
- getMessageHandlerMethodFactory() - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistrar
- getMessageId() - Method in class org.springframework.amqp.core.MessageProperties
- getMessageId() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getMessageListener() - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerEndpoint
- getMessageListener() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Get a reference to the message listener.
- getMessageListener() - Method in interface org.springframework.amqp.rabbit.listener.MessageListenerContainer
-
Get the message listener.
- getMessageListener() - Method in class org.springframework.rabbit.stream.listener.StreamListenerContainer
- getMessageProperties() - Method in class org.springframework.amqp.core.Message
- getMessageProperties() - Method in class org.springframework.amqp.rabbit.core.BrokerEvent
-
The complete
MessageProperties
from the event representing the event. - getMessagePropertiesConverter() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
-
Return the converter for properties.
- getMessagePropertiesConverter() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getMessageRecoverer() - Method in class org.springframework.amqp.rabbit.config.AbstractRetryOperationsInterceptorFactoryBean
- getMessagingMessageConverter() - Method in class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter
- getMethod() - Method in class org.springframework.amqp.rabbit.listener.adapter.InvocationResult
- getMethod() - Method in class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter.MessagingMessageConverterAdapter
- getMethod() - Method in class org.springframework.amqp.rabbit.listener.MethodRabbitListenerEndpoint
- getMethodAsString(Object) - Method in class org.springframework.amqp.rabbit.listener.adapter.HandlerAdapter
-
Get the method signature for the payload type via
Method.toGenericString()
. - getMethodFor(Object) - Method in class org.springframework.amqp.rabbit.listener.adapter.DelegatingInvocableHandler
-
Return the method that will be invoked for this payload.
- getMethodFor(Object) - Method in class org.springframework.amqp.rabbit.listener.adapter.HandlerAdapter
-
Get the method for the payload type.
- getMethodNameFor(Object) - Method in class org.springframework.amqp.rabbit.listener.adapter.DelegatingInvocableHandler
-
Return a string representation of the method that will be invoked for this payload.
- getMicrometerEnabled() - Method in class org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory
- getMicrometerHolder() - Method in class org.springframework.amqp.rabbit.listener.ObservableListenerContainer
- getNackCause() - Method in class org.springframework.amqp.rabbit.RabbitFuture
-
When confirms are enabled and a nack is received, contains the cause for the nack, if any.
- getName() - Method in class org.springframework.amqp.core.AbstractExchange
- getName() - Method in interface org.springframework.amqp.core.Exchange
-
The name of the exchange.
- getName() - Method in class org.springframework.amqp.core.Queue
-
Return the name provided in the constructor.
- getName() - Method in class org.springframework.amqp.core.QueueInformation
- getName() - Method in interface org.springframework.amqp.rabbit.support.micrometer.RabbitListenerObservationConvention
- getName() - Method in interface org.springframework.amqp.rabbit.support.micrometer.RabbitTemplateObservationConvention
- getName() - Method in interface org.springframework.rabbit.stream.micrometer.RabbitStreamListenerObservationConvention
- getName() - Method in interface org.springframework.rabbit.stream.micrometer.RabbitStreamTemplateObservationConvention
- getNewConsumer() - Method in class org.springframework.amqp.rabbit.listener.AsyncConsumerRestartedEvent
- getNextInvocationDataFor(String, long, TimeUnit) - Method in class org.springframework.amqp.rabbit.test.RabbitListenerTestHarness
- getNextPublishSeqNo() - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- getObject() - Method in class org.springframework.amqp.rabbit.config.BindingFactoryBean
- getObject() - Method in class org.springframework.amqp.rabbit.config.StatefulRetryOperationsInterceptorFactoryBean
- getObject() - Method in class org.springframework.amqp.rabbit.config.StatelessRetryOperationsInterceptorFactoryBean
- getObjectType() - Method in class org.springframework.amqp.rabbit.config.BindingFactoryBean
- getObjectType() - Method in class org.springframework.amqp.rabbit.config.ListenerContainerFactoryBean
- getObjectType() - Method in class org.springframework.amqp.rabbit.config.StatefulRetryOperationsInterceptorFactoryBean
- getObjectType() - Method in class org.springframework.amqp.rabbit.config.StatelessRetryOperationsInterceptorFactoryBean
- getObjectType() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
- getObjectType() - Method in class org.springframework.amqp.rabbit.support.ExpressionFactoryBean
- getObservationEnabled() - Method in class org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory
- getObservationRegistry() - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor
- getOldConsumer() - Method in class org.springframework.amqp.rabbit.listener.AsyncConsumerRestartedEvent
- getOrCreateArguments() - Method in class org.springframework.amqp.core.AbstractBuilder
-
Return the arguments map, after creating one if necessary.
- getOrder() - Method in class org.springframework.amqp.rabbit.annotation.RabbitListenerAnnotationBeanPostProcessor
- getOrder() - Method in class org.springframework.amqp.support.postprocessor.AbstractCompressingPostProcessor
- getOrder() - Method in class org.springframework.amqp.support.postprocessor.AbstractDecompressingPostProcessor
- getOrder() - Method in class org.springframework.amqp.support.postprocessor.DelegatingDecompressingPostProcessor
- getPassword() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunning
-
Return the password.
- getPassword() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
-
Return the password.
- getPassword() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getPendingConfirmsCount() - Method in interface org.springframework.amqp.rabbit.connection.PublisherCallbackChannel
-
Get the total pending confirms count.
- getPendingConfirmsCount() - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- getPendingConfirmsCount(PublisherCallbackChannel.Listener) - Method in interface org.springframework.amqp.rabbit.connection.PublisherCallbackChannel
-
Get the
PendingConfirm
s count. - getPendingConfirmsCount(PublisherCallbackChannel.Listener) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- getPhase() - Method in class org.springframework.amqp.rabbit.AsyncRabbitTemplate
- getPhase() - Method in class org.springframework.amqp.rabbit.config.ListenerContainerFactoryBean
- getPhase() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
- getPhase() - Method in class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
- getPhase() - Method in class org.springframework.amqp.rabbit.connection.PooledChannelConnectionFactory
- getPhase() - Method in class org.springframework.amqp.rabbit.connection.ThreadChannelConnectionFactory
- getPhase() - Method in class org.springframework.amqp.rabbit.core.BrokerEventListener
- getPhase() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getPhase() - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry
- getPhase() - Method in class org.springframework.rabbit.stream.support.StreamAdmin
- getPort() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- getPort() - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory
- getPort() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactory
- getPort() - Method in class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
- getPort() - Method in class org.springframework.amqp.rabbit.connection.SimpleConnection
- getPort() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunning
-
Return the port.
- getPort() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
-
Return the port.
- getPort() - Static method in class org.springframework.amqp.rabbit.junit.BrokerTestUtils
-
The port that the broker is listening on (e.g.
- getPort() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getPrefetchCount() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Return the prefetch count.
- getPriority() - Method in class org.springframework.amqp.core.MessageProperties
- getPriority() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getPriority() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getProperties() - Method in class org.springframework.amqp.rabbit.log4j2.AmqpAppender.Event
- getProperties() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender.Event
- getProperties() - Method in class org.springframework.amqp.rabbit.support.Delivery
-
Retrieve the message properties.
- getPropertyValue(Object, String) - Static method in class org.springframework.amqp.utils.test.TestUtils
-
Uses nested
DirectFieldAccessor
s to obtain a property using dotted notation to traverse fields; e.g. - getPropertyValue(Object, String, Class<T>) - Static method in class org.springframework.amqp.utils.test.TestUtils
- getPublisherConnectionFactory() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- getPublisherConnectionFactory() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactory
-
Return a separate connection factory for publishers (if implemented).
- getPublisherConnectionFactoryCacheProperties() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
-
Return the cache properties from the underlying publisher sub-factory.
- getPublishSequenceNumber() - Method in class org.springframework.amqp.core.MessageProperties
-
Return the publish sequence number if publisher confirms are enabled; set by the template.
- getQueue() - Method in class org.springframework.amqp.rabbit.listener.ConsumeOkEvent
-
Obtain the queue name a consumer has been subscribed.
- getQueue() - Method in class org.springframework.amqp.rabbit.listener.MissingQueueEvent
-
Return the missing queue.
- getQueue() - Method in class org.springframework.amqp.rabbit.support.Delivery
-
Retrieve the queue.
- getQueuedEventCount() - Method in class org.springframework.amqp.rabbit.log4j2.AmqpAppender
-
Return the number of events waiting to be sent.
- getQueuedEventCount() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
-
Return the number of events waiting to be sent.
- getQueueInfo(String) - Method in interface org.springframework.amqp.core.AmqpAdmin
-
Returns information about the queue, if it exists.
- getQueueInfo(String) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
- getQueueNames() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getQueueNames() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getQueueNames() - Method in class org.springframework.amqp.rabbit.listener.ListenerContainerIdleEvent
-
The queues the container is listening to.
- getQueueNamesAsSet() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getQueueNamesToQueues() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Returns a map of current queue names to the Queue object; allows the determination of a changed broker-named queue.
- getQueueProperties(String) - Method in interface org.springframework.amqp.core.AmqpAdmin
-
Returns an implementation-specific Map of properties if the queue exists.
- getQueueProperties(String) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
-
Returns 3 properties
RabbitAdmin.QUEUE_NAME
,RabbitAdmin.QUEUE_MESSAGE_COUNT
,RabbitAdmin.QUEUE_CONSUMER_COUNT
, or null if the queue doesn't exist. - getQueues() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getRabbitConnectionFactory() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
-
Return a reference to the underlying Rabbit Connection factory.
- getRabbitConnectionFactory() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
-
Access the connection factory to set any other properties not supported by this factory bean.
- getRabbitOperations() - Method in class org.springframework.amqp.rabbit.core.RabbitGatewaySupport
- getRabbitTemplate() - Method in class org.springframework.amqp.rabbit.AsyncRabbitTemplate
-
Return the underlying
RabbitTemplate
used for sending. - getRabbitTemplate() - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
- getRabbitTemplate() - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
- getReason() - Method in class org.springframework.amqp.rabbit.connection.ConnectionBlockedEvent
- getReason() - Method in class org.springframework.amqp.rabbit.connection.CorrelationData.Confirm
- getReason() - Method in class org.springframework.amqp.rabbit.listener.ListenerContainerConsumerFailedEvent
- getReason() - Method in class org.springframework.amqp.rabbit.listener.ListenerContainerConsumerTerminatedEvent
- getReceivedDelayLong() - Method in class org.springframework.amqp.core.MessageProperties
-
When a delayed message exchange is used the x-delay header on a received message contains the delay.
- getReceivedDeliveryMode() - Method in class org.springframework.amqp.core.MessageProperties
- getReceivedDeliveryMode() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getReceivedExchange() - Method in class org.springframework.amqp.core.MessageProperties
- getReceivedExchange() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getReceivedExchange(Message) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener
- getReceivedRoutingKey() - Method in class org.springframework.amqp.core.MessageProperties
- getReceivedRoutingKey() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getReceivedUserId() - Method in class org.springframework.amqp.core.MessageProperties
-
Return the user id from an incoming message.
- getReceivedUserId() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getRecoveryBackOff() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getRedelivered() - Method in class org.springframework.amqp.core.MessageProperties
- getRedelivered() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getReplyCode() - Method in exception org.springframework.amqp.core.AmqpMessageReturnedException
- getReplyCode() - Method in class org.springframework.amqp.core.ReturnedMessage
-
Get the reply code.
- getReplyContentType() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getReplyContentType() - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener
-
Get the reply content type.
- getReplyContentType() - Method in interface org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint
-
Get the reply content type.
- getReplyPostProcessor() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getReplyPostProcessor() - Method in interface org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint
-
Return a
ReplyPostProcessor
to post process a reply message before it is sent. - getReplyText() - Method in exception org.springframework.amqp.core.AmqpMessageReturnedException
- getReplyText() - Method in class org.springframework.amqp.core.ReturnedMessage
-
Get the reply text.
- getReplyTo() - Method in class org.springframework.amqp.core.MessageProperties
- getReplyTo() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getReplyToAddress() - Method in class org.springframework.amqp.core.MessageProperties
- getReplyToAddress(Message, Object, InvocationResult) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener
-
Determine a reply-to Address for the given message.
- getReplyToAddress(Message, T) - Method in interface org.springframework.amqp.core.ReplyToAddressCallback
- getReplyToGroupId() - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
-
See
Properties.getReplyToGroupId()
. - getRequest() - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener.ReplyExpressionRoot
- getRequestMessage() - Method in exception org.springframework.amqp.core.AmqpReplyTimeoutException
- getResolver() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getResourceFactory() - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
- getResourceLoader() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
-
Get the resource loader; used to resolve the key store and trust store
Resource
s to input streams. - getResources() - Static method in class org.springframework.amqp.rabbit.connection.SimpleResourceHolder
-
Return all resources that are bound to the current thread.
- getResult() - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener.ReplyExpressionRoot
- getResult() - Method in class org.springframework.amqp.rabbit.test.RabbitListenerTestHarness.InvocationData
- getRetryOperations() - Method in class org.springframework.amqp.rabbit.config.AbstractRetryOperationsInterceptorFactoryBean
- getReturned() - Method in exception org.springframework.amqp.core.AmqpMessageReturnedException
- getReturned() - Method in class org.springframework.amqp.rabbit.connection.CorrelationData
-
Get the returned message and metadata, if any.
- getReturnedMessage() - Method in exception org.springframework.amqp.core.AmqpMessageReturnedException
- getReturnType() - Method in class org.springframework.amqp.rabbit.listener.adapter.InvocationResult
- getReturnType() - Method in class org.springframework.amqp.rabbit.RabbitConverterFuture
- getReturnTypeFor(Object) - Method in class org.springframework.amqp.rabbit.listener.adapter.HandlerAdapter
-
Return the return type for the method that will be chosen for this payload.
- getReturnValue() - Method in class org.springframework.amqp.rabbit.listener.adapter.InvocationResult
- getRoutingConnectionFactory() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Return the (@link RoutingConnectionFactory} if the connection factory is a
RoutingConnectionFactory
; null otherwise. - getRoutingKey() - Method in class org.springframework.amqp.core.Address
- getRoutingKey() - Method in exception org.springframework.amqp.core.AmqpMessageReturnedException
- getRoutingKey() - Method in class org.springframework.amqp.core.Binding
- getRoutingKey() - Method in class org.springframework.amqp.core.ReturnedMessage
-
Get the routing key.
- getRoutingKey() - Method in class org.springframework.amqp.rabbit.batch.MessageBatch
- getRoutingKey() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- getRoutingKey() - Method in class org.springframework.amqp.rabbit.support.micrometer.RabbitMessageSenderContext
-
Return the routingKey.
- getRoutingKeyPattern() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getRoutingLookupKey() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Return the lookup key if the connection factory is a
RoutingConnectionFactory
; null otherwise. - getSaslConfig() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getSecureRandom() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
- getSenderPoolSize() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getSendTo() - Method in class org.springframework.amqp.rabbit.listener.adapter.InvocationResult
- getShutdownTimeout() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getSource() - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener.ReplyExpressionRoot
- getSource() - Method in class org.springframework.amqp.rabbit.support.micrometer.RabbitMessageReceiverContext
-
Return the source (queue) for this message.
- getSource() - Method in class org.springframework.rabbit.stream.micrometer.RabbitStreamMessageReceiverContext
-
Return the source (stream) for this message.
- getSpy(String) - Method in class org.springframework.amqp.rabbit.test.RabbitListenerTestHarness
- getSslAlgorithm() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
- getSslAlgorithm() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getSslPropertiesLocation() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
- getSslPropertiesLocation() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getStackTraceAsString(Throwable) - Method in class org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer
-
Create a String representation of the stack trace.
- getStreamConverter() - Method in class org.springframework.rabbit.stream.listener.StreamListenerContainer
- getSubject() - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
-
See
Properties.getSubject()
. - getSupportedContentType() - Method in class org.springframework.amqp.support.converter.AbstractJackson2MessageConverter
-
Get the supported content type; only the subtype is checked when decoding, e.g.
- getSyncStatus() - Method in exception org.springframework.amqp.rabbit.connection.AfterCompletionFailedException
-
Return the synchronization status.
- getTargetBean() - Method in class org.springframework.amqp.core.MessageProperties
-
The target bean when using
@RabbitListener
. - getTargetChannel() - Method in interface org.springframework.amqp.rabbit.connection.ChannelProxy
-
Return the target Channel of this proxy.
- getTargetConnection() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionProxy
-
Return the target Channel of this proxy.
- getTargetConnectionFactory(Object) - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory
- getTargetConnectionFactory(Object) - Method in class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
- getTargetConnectionFactory(Object) - Method in interface org.springframework.amqp.rabbit.connection.RoutingConnectionFactory
-
Returns the
ConnectionFactory
bound to given lookup key, or null if one does not exist. - getTargetMethod() - Method in class org.springframework.amqp.core.MessageProperties
-
The target method when using a
@RabbitListener
. - getTaskExecutor() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getTaskExecutor() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getTaskExecutor() - Method in interface org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint
-
Get the task executor to use for this endpoint's listener container.
- getThrowable() - Method in class org.springframework.amqp.rabbit.core.DeclarationExceptionEvent
- getThrowable() - Method in class org.springframework.amqp.rabbit.listener.ListenerContainerConsumerFailedEvent
- getThrowable() - Method in class org.springframework.amqp.rabbit.test.RabbitListenerTestHarness.InvocationData
- getTimestamp() - Method in class org.springframework.amqp.core.MessageProperties
- getTimestamp() - Method in class org.springframework.amqp.rabbit.connection.PendingConfirm
- getTimestamp() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getTo() - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
-
See
Properties.getTo()
. - getTransactionalResourceHolder() - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor
- getTransactionalResourceHolder(ConnectionFactory, boolean) - Static method in class org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils
-
Obtain a RabbitMQ Channel that is synchronized with the current transaction, if any.
- getTransactionalResourceHolder(ConnectionFactory, boolean, boolean) - Static method in class org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils
-
Obtain a RabbitMQ Channel that is synchronized with the current transaction, if any.
- getTransactionAttribute() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getTransactionManager() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getTrustStore() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
- getTrustStore() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getTrustStoreAlgorithm() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
- getTrustStorePassphrase() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
- getTrustStorePassphrase() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getTrustStoreResource() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
- getTrustStoreType() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
-
Get the trust store type - this defaults to JKS if not overridden by
RabbitConnectionFactoryBean.setSslPropertiesLocation(Resource)
orRabbitConnectionFactoryBean.setTrustStoreType(java.lang.String)
. - getTrustStoreType() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getType() - Method in class org.springframework.amqp.core.AbstractExchange
- getType() - Method in class org.springframework.amqp.core.ConsistentHashExchange
- getType() - Method in class org.springframework.amqp.core.CustomExchange
- getType() - Method in class org.springframework.amqp.core.DirectExchange
- getType() - Method in interface org.springframework.amqp.core.Exchange
-
The type of the exchange.
- getType() - Method in class org.springframework.amqp.core.FanoutExchange
- getType() - Method in class org.springframework.amqp.core.HeadersExchange
- getType() - Method in class org.springframework.amqp.core.MessageProperties
- getType() - Method in class org.springframework.amqp.core.TopicExchange
- getType() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getTypePrecedence() - Method in class org.springframework.amqp.support.converter.AbstractJackson2MessageConverter
-
Return the type precedence.
- getTypePrecedence() - Method in class org.springframework.amqp.support.converter.DefaultJackson2JavaTypeMapper
-
Return the precedence.
- getTypePrecedence() - Method in interface org.springframework.amqp.support.converter.Jackson2JavaTypeMapper
-
Get the type precedence.
- getUnconfirmed(long) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
-
Gets unconfirmed correlation data older than age and removes them.
- getUnconfirmedCount() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
-
Gets unconfirmed messages count.
- getUri() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getUser() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunning
-
Return the user.
- getUser() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
-
Return the user.
- getUserId() - Method in class org.springframework.amqp.core.MessageProperties
- getUserId() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getUsername() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
-
Return the user name from the underlying rabbit connection factory.
- getUsername() - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory
- getUsername() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactory
- getUsername() - Method in class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
- getUsername() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getUUID() - Method in interface org.springframework.amqp.rabbit.connection.PublisherCallbackChannel.Listener
-
Returns the UUID used to identify this Listener for returns.
- getUUID() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- getValidator() - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistrar
-
Get the validator, if supplied.
- getValue() - Method in enum class org.springframework.amqp.core.QueueBuilder.LeaderLocator
-
Return the value.
- getValue() - Method in enum class org.springframework.amqp.core.QueueBuilder.Overflow
-
Return the value.
- getValue() - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getValue() - Method in class org.springframework.amqp.support.converter.RemoteInvocationResult
-
Return the result value returned by a successful invocation of the target method, if any.
- getValue(Class<T>) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getValue(Object) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getValue(Object, Class<T>) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getValue(EvaluationContext) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getValue(EvaluationContext, Class<T>) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getValue(EvaluationContext, Object) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getValue(EvaluationContext, Object, Class<T>) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getValueType() - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getValueType(Object) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getValueType(EvaluationContext) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getValueType(EvaluationContext, Object) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getValueTypeDescriptor() - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getValueTypeDescriptor(Object) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getValueTypeDescriptor(EvaluationContext) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getValueTypeDescriptor(EvaluationContext, Object) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getVirtualHost() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- getVirtualHost() - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory
- getVirtualHost() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactory
- getVirtualHost() - Method in class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
- getVirtualHost() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getXDeathHeader() - Method in class org.springframework.amqp.core.MessageProperties
-
Return the x-death header.
- group() - Element in annotation interface org.springframework.amqp.rabbit.annotation.RabbitListener
-
If provided, the listener container for this listener will be added to a bean with this value as its name, of type
Collection<MessageListenerContainer>
. - GUnzipPostProcessor - Class in org.springframework.amqp.support.postprocessor
-
A post processor that uses a
GZIPInputStream
to decompress the message body. - GUnzipPostProcessor() - Constructor for class org.springframework.amqp.support.postprocessor.GUnzipPostProcessor
- GUnzipPostProcessor(boolean) - Constructor for class org.springframework.amqp.support.postprocessor.GUnzipPostProcessor
- GZipPostProcessor - Class in org.springframework.amqp.support.postprocessor
-
A post processor that uses a
GZIPOutputStream
to compress the message body. - GZipPostProcessor() - Constructor for class org.springframework.amqp.support.postprocessor.GZipPostProcessor
- GZipPostProcessor(boolean) - Constructor for class org.springframework.amqp.support.postprocessor.GZipPostProcessor
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form