Class SimpleRabbitListenerEndpoint
- java.lang.Object
-
- org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
-
- org.springframework.amqp.rabbit.config.SimpleRabbitListenerEndpoint
-
- All Implemented Interfaces:
RabbitListenerEndpoint,Aware,BeanFactoryAware
public class SimpleRabbitListenerEndpoint extends AbstractRabbitListenerEndpoint
ARabbitListenerEndpointsimply providing theMessageListenerto invoke to process an incoming message for this endpoint.- Since:
- 1.4
- Author:
- Stephane Nicoll
-
-
Constructor Summary
Constructors Constructor Description SimpleRabbitListenerEndpoint()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected MessageListenercreateMessageListener(MessageListenerContainer container)Create aMessageListenerthat is able to serve this endpoint for the specified container.protected java.lang.StringBuildergetEndpointDescription()MessageListenergetMessageListener()voidsetMessageListener(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
-
-
-
-
Method Detail
-
setMessageListener
public void setMessageListener(MessageListener messageListener)
Set theMessageListenerto invoke when a message matching the endpoint is received.- Parameters:
messageListener- theMessageListenerinstance.
-
getMessageListener
public MessageListener getMessageListener()
- Returns:
- the
MessageListenerto invoke when a message matching the endpoint is received.
-
createMessageListener
protected 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
protected java.lang.StringBuilder getEndpointDescription()
- Overrides:
getEndpointDescriptionin classAbstractRabbitListenerEndpoint- Returns:
- a description for this endpoint.
Available to subclasses, for inclusion in their
toString()result.
-
-