Class SimpleRabbitListenerEndpoint
java.lang.Object
org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
org.springframework.amqp.rabbit.config.SimpleRabbitListenerEndpoint
- All Implemented Interfaces:
RabbitListenerEndpoint,Aware,BeanFactoryAware
A
RabbitListenerEndpoint simply
providing the MessageListener to invoke to process an incoming message for this
endpoint.- Since:
- 1.4
- Author:
- Stephane Nicoll
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected MessageListenercreateMessageListener(MessageListenerContainer container) Create aMessageListenerthat is able to serve this endpoint for the specified container.protected StringBuildervoidsetMessageListener(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, 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
Set theMessageListenerto invoke when a message matching the endpoint is received.- Parameters:
messageListener- theMessageListenerinstance.
-
getMessageListener
- Returns:
- the
MessageListenerto invoke when a message matching the endpoint is received.
-
createMessageListener
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.
-