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
public class SimpleRabbitListenerEndpoint extends AbstractRabbitListenerEndpoint
ARabbitListenerEndpointsimply providing theMessageListenerto invoke to process an incoming message for this endpoint.- Since:
- 1.4
-
-
Constructor Summary
Constructors Constructor Description SimpleRabbitListenerEndpoint()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected org.springframework.amqp.core.MessageListenercreateMessageListener(MessageListenerContainer container)Create aMessageListenerthat is able to serve this endpoint for the specified container.protected java.lang.StringBuildergetEndpointDescription()org.springframework.amqp.core.MessageListenergetMessageListener()voidsetMessageListener(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, 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(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
protected java.lang.StringBuilder getEndpointDescription()
- Overrides:
getEndpointDescriptionin classAbstractRabbitListenerEndpoint- Returns:
- a description for this endpoint.
Available to subclasses, for inclusion in their
toString()result.
-
-