Class SimpleRabbitListenerEndpoint
java.lang.Object
org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
org.springframework.amqp.rabbit.config.SimpleRabbitListenerEndpoint
- All Implemented Interfaces:
RabbitListenerEndpoint,org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanFactoryAware
A
RabbitListenerEndpoint simply
providing the MessageListener to invoke to process an incoming message for this
endpoint.- Since:
- 1.4
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected org.springframework.amqp.core.MessageListenercreateMessageListener(MessageListenerContainer container) Create aMessageListenerthat is able to serve this endpoint for the specified container.protected StringBuilderorg.springframework.amqp.core.MessageListenervoidsetMessageListener(org.springframework.amqp.core.MessageListener messageListener) Set theMessageListenerto invoke when a message matching the endpoint is received.Methods inherited from class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
getAckMode, getAdmin, getAutoStartup, getBatchingStrategy, getBatchListener, getBeanExpressionContext, getBeanFactory, getBeanResolver, getConcurrency, getGroup, getId, getMessageConverter, getPriority, getQueueNames, getQueues, getReplyContentType, getReplyPostProcessor, getResolver, getTaskExecutor, isBatchListener, isConverterWinsContentType, isExclusive, setAckMode, setAdmin, setAutoStartup, setBatchingStrategy, setBatchListener, setBeanFactory, setConcurrency, setConverterWinsContentType, setExclusive, setGroup, setId, setMessageConverter, setPriority, setQueueNames, setQueues, setReplyContentType, setReplyPostProcessor, setTaskExecutor, setupListenerContainer, toString
-
Constructor Details
-
SimpleRabbitListenerEndpoint
public SimpleRabbitListenerEndpoint()
-
-
Method Details
-
setMessageListener
public void setMessageListener(org.springframework.amqp.core.MessageListener messageListener) Set theMessageListenerto invoke when a message matching the endpoint is received.- Parameters:
messageListener- theMessageListenerinstance.
-
getMessageListener
public org.springframework.amqp.core.MessageListener getMessageListener()- Returns:
- the
MessageListenerto invoke when a message matching the endpoint is received.
-
createMessageListener
protected org.springframework.amqp.core.MessageListener createMessageListener(MessageListenerContainer container) Description copied from class:AbstractRabbitListenerEndpointCreate aMessageListenerthat is able to serve this endpoint for the specified container.- Specified by:
createMessageListenerin classAbstractRabbitListenerEndpoint- Parameters:
container- theMessageListenerContainerto create aMessageListener.- Returns:
- a a
MessageListenerinstance.
-
getEndpointDescription
- Overrides:
getEndpointDescriptionin classAbstractRabbitListenerEndpoint- Returns:
- a description for this endpoint.
Available to subclasses, for inclusion in their
toString()result.
-