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
ARabbitListenerEndpoint
simply providing theMessageListener
to 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 MessageListener
createMessageListener(MessageListenerContainer container)
Create aMessageListener
that is able to serve this endpoint for the specified container.protected StringBuilder
getEndpointDescription()
MessageListener
getMessageListener()
void
setMessageListener(MessageListener messageListener)
Set theMessageListener
to 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 theMessageListener
to invoke when a message matching the endpoint is received.- Parameters:
messageListener
- theMessageListener
instance.
-
getMessageListener
public MessageListener getMessageListener()
- Returns:
- the
MessageListener
to invoke when a message matching the endpoint is received.
-
createMessageListener
protected MessageListener createMessageListener(MessageListenerContainer container)
Description copied from class:AbstractRabbitListenerEndpoint
Create aMessageListener
that is able to serve this endpoint for the specified container.- Specified by:
createMessageListener
in classAbstractRabbitListenerEndpoint
- Parameters:
container
- theMessageListenerContainer
to create aMessageListener
.- Returns:
- a a
MessageListener
instance.
-
getEndpointDescription
protected StringBuilder getEndpointDescription()
- Overrides:
getEndpointDescription
in classAbstractRabbitListenerEndpoint
- Returns:
- a description for this endpoint.
Available to subclasses, for inclusion in their
toString()
result.
-
-