public class PointToPointSubscribableAmqpChannel extends AbstractAmqpChannel
AbstractMessageChannel.ChannelInterceptorListlogger| Constructor and Description |
|---|
PointToPointSubscribableAmqpChannel(java.lang.String channelName,
org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer container,
org.springframework.amqp.core.AmqpTemplate amqpTemplate) |
| Modifier and Type | Method and Description |
|---|---|
protected AbstractDispatcher |
createDispatcher() |
void |
destroy() |
int |
getPhase() |
protected java.lang.String |
getRoutingKey()
Subclasses may override this method to return a routing key.
|
protected org.springframework.amqp.core.Queue |
initializeQueue(org.springframework.amqp.core.AmqpAdmin admin,
java.lang.String channelName) |
boolean |
isAutoStartup() |
boolean |
isRunning() |
void |
onInit()
Subclasses may implement this for initialization logic.
|
void |
setMaxSubscribers(int maxSubscribers)
Specify the maximum number of subscribers supported by the
channel's dispatcher (if it is an
AbstractDispatcher). |
void |
setQueueName(java.lang.String queueName)
Provide a Queue name to be used.
|
void |
start() |
void |
stop() |
void |
stop(java.lang.Runnable callback) |
boolean |
subscribe(MessageHandler handler)
Register a
MessageHandler as a subscriber to this channel. |
boolean |
unsubscribe(MessageHandler handler)
Remove a
MessageHandler from the subscribers of this channel. |
doSend, getExchangeNameaddInterceptor, getComponentType, getFullChannelName, getInterceptors, send, send, setConversionService, setDatatypes, setInterceptors, setShouldTrackafterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setTaskScheduler, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitsend, sendgetComponentNamepublic PointToPointSubscribableAmqpChannel(java.lang.String channelName,
org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer container,
org.springframework.amqp.core.AmqpTemplate amqpTemplate)
public void setQueueName(java.lang.String queueName)
protected org.springframework.amqp.core.Queue initializeQueue(org.springframework.amqp.core.AmqpAdmin admin,
java.lang.String channelName)
protected AbstractDispatcher createDispatcher()
protected java.lang.String getRoutingKey()
AbstractAmqpChannelgetRoutingKey in class AbstractAmqpChannelpublic void setMaxSubscribers(int maxSubscribers)
AbstractDispatcher).maxSubscribers - public boolean subscribe(MessageHandler handler)
SubscribableChannelMessageHandler as a subscriber to this channel.subscribe in interface SubscribableChannelpublic boolean unsubscribe(MessageHandler handler)
SubscribableChannelMessageHandler from the subscribers of this channel.unsubscribe in interface SubscribableChannelpublic void onInit()
throws java.lang.Exception
IntegrationObjectSupportonInit in class IntegrationObjectSupportjava.lang.Exceptionpublic boolean isAutoStartup()
isAutoStartup in interface org.springframework.context.SmartLifecyclepublic int getPhase()
getPhase in interface org.springframework.context.Phasedpublic boolean isRunning()
isRunning in interface org.springframework.context.Lifecyclepublic void start()
start in interface org.springframework.context.Lifecyclepublic void stop()
stop in interface org.springframework.context.Lifecyclepublic void stop(java.lang.Runnable callback)
stop in interface org.springframework.context.SmartLifecyclepublic void destroy()
throws java.lang.Exception
destroy in interface org.springframework.beans.factory.DisposableBeanjava.lang.Exception