public abstract class AbstractRabbitListenerEndpoint extends Object implements RabbitListenerEndpoint, BeanFactoryAware
MethodRabbitListenerEndpoint
,
SimpleRabbitListenerEndpoint
Constructor and Description |
---|
AbstractRabbitListenerEndpoint() |
Modifier and Type | Method and Description |
---|---|
protected abstract MessageListener |
createMessageListener(MessageListenerContainer container)
Create a
MessageListener that is able to serve this endpoint for the
specified container. |
AmqpAdmin |
getAdmin() |
Boolean |
getAutoStartup()
Override of the default autoStartup property.
|
protected BeanExpressionContext |
getBeanExpressionContext() |
protected BeanFactory |
getBeanFactory() |
protected BeanResolver |
getBeanResolver() |
String |
getConcurrency()
The concurrency of this endpoint; Not used by this abstract class;
used by subclasses to set the concurrency appropriate for the container type.
|
protected StringBuilder |
getEndpointDescription() |
String |
getGroup() |
String |
getId() |
MessageConverter |
getMessageConverter()
Used by the container factory to check if this endpoint supports the
preferred way for a container factory to pass a message converter
to the endpoint's adapter.
|
Integer |
getPriority() |
Collection<String> |
getQueueNames() |
Collection<Queue> |
getQueues() |
protected BeanExpressionResolver |
getResolver() |
boolean |
isExclusive() |
void |
setAdmin(AmqpAdmin admin)
Set the
AmqpAdmin instance to use. |
void |
setAutoStartup(Boolean autoStartup)
Override the default autoStartup property.
|
void |
setBeanFactory(BeanFactory beanFactory) |
void |
setConcurrency(String concurrency)
Set the concurrency of this endpoint; usually overrides any concurrency
settings on the container factory.
|
void |
setExclusive(boolean exclusive)
Set if a single consumer in the container will have exclusive use of the
queues, preventing other consumers from receiving messages from the
queue(s).
|
void |
setGroup(String group)
Set the group for the corresponding listener container.
|
void |
setId(String id) |
void |
setMessageConverter(MessageConverter messageConverter)
The preferred way for a container factory to pass a message converter
to the endpoint's adapter.
|
void |
setPriority(Integer priority)
Set the priority of this endpoint.
|
void |
setQueueNames(String... queueNames)
Set the queue names to use.
|
void |
setQueues(Queue... queues)
Set the queues to use.
|
void |
setupListenerContainer(MessageListenerContainer listenerContainer)
Setup the specified message listener container with the model
defined by this endpoint.
|
String |
toString() |
public void setBeanFactory(BeanFactory beanFactory) throws BeansException
setBeanFactory
in interface BeanFactoryAware
BeansException
@Nullable protected BeanFactory getBeanFactory()
protected BeanExpressionResolver getResolver()
protected BeanResolver getBeanResolver()
protected BeanExpressionContext getBeanExpressionContext()
public void setId(String id)
public String getId()
getId
in interface RabbitListenerEndpoint
RabbitListenerContainerFactory.createListenerContainer(org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint)
public void setQueues(Queue... queues)
Queue
instances or the
queue names should be provided, but not both.queues
- to set.setQueueNames(java.lang.String...)
public Collection<Queue> getQueues()
public Collection<String> getQueueNames()
public void setQueueNames(String... queueNames)
Queue
instances or the
queue names should be provided, but not both.queueNames
- to set.setQueues(org.springframework.amqp.core.Queue...)
public void setExclusive(boolean exclusive)
exclusive
- the exclusive boolean
flag.public boolean isExclusive()
boolean
flag.public void setPriority(Integer priority)
priority
- the priority value.public Integer getPriority()
null
if
no priority is set.public void setConcurrency(String concurrency)
concurrency
- the concurrency.public String getConcurrency()
getConcurrency
in interface RabbitListenerEndpoint
public void setAdmin(AmqpAdmin admin)
AmqpAdmin
instance to use.admin
- the AmqpAdmin
instance.public AmqpAdmin getAdmin()
AmqpAdmin
instance to use or null
if
none is configured.public String getGroup()
getGroup
in interface RabbitListenerEndpoint
public void setGroup(String group)
group
- the group.public void setAutoStartup(Boolean autoStartup)
autoStartup
- the autoStartup.public Boolean getAutoStartup()
RabbitListenerEndpoint
getAutoStartup
in interface RabbitListenerEndpoint
public MessageConverter getMessageConverter()
RabbitListenerEndpoint
getMessageConverter
in interface RabbitListenerEndpoint
public void setMessageConverter(MessageConverter messageConverter)
RabbitListenerEndpoint
setMessageConverter
in interface RabbitListenerEndpoint
messageConverter
- the converter.public void setupListenerContainer(MessageListenerContainer listenerContainer)
RabbitListenerEndpoint
This endpoint must provide the requested missing option(s) of
the specified container to make it usable. Usually, this is about
setting the queues
and the messageListener
to
use but an implementation may override any default setting that
was already set.
setupListenerContainer
in interface RabbitListenerEndpoint
listenerContainer
- the listener container to configureprotected abstract MessageListener createMessageListener(MessageListenerContainer container)
MessageListener
that is able to serve this endpoint for the
specified container.container
- the MessageListenerContainer
to create a MessageListener
.MessageListener
instance.protected StringBuilder getEndpointDescription()
Available to subclasses, for inclusion in their toString()
result.