public class PublishSubscribeAmqpChannel extends AbstractAmqpChannel
| Constructor and Description |
|---|
PublishSubscribeAmqpChannel(java.lang.String channelName,
org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer container,
org.springframework.amqp.core.AmqpTemplate amqpTemplate) |
| Modifier and Type | Method and Description |
|---|---|
protected org.springframework.integration.dispatcher.AbstractDispatcher |
createDispatcher() |
void |
destroy() |
protected java.lang.String |
getExchangeName()
Subclasses may override this method to return an Exchange name.
|
int |
getPhase() |
protected org.springframework.amqp.core.Queue |
initializeQueue(org.springframework.amqp.core.AmqpAdmin admin,
java.lang.String channelName) |
boolean |
isAutoStartup() |
boolean |
isRunning() |
void |
onInit() |
void |
setExchange(org.springframework.amqp.core.FanoutExchange exchange)
Configure the FanoutExchange instance.
|
void |
setMaxSubscribers(int maxSubscribers)
Specify the maximum number of subscribers supported by the
channel's dispatcher (if it is an
AbstractDispatcher). |
void |
start() |
void |
stop() |
void |
stop(java.lang.Runnable callback) |
boolean |
subscribe(org.springframework.integration.core.MessageHandler handler) |
boolean |
unsubscribe(org.springframework.integration.core.MessageHandler handler) |
doSend, getRoutingKeyaddInterceptor, getComponentType, getFullChannelName, getInterceptors, send, send, setConversionService, setDatatypes, setInterceptors, setShouldTrackafterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setTaskScheduler, toStringpublic PublishSubscribeAmqpChannel(java.lang.String channelName,
org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer container,
org.springframework.amqp.core.AmqpTemplate amqpTemplate)
public void setExchange(org.springframework.amqp.core.FanoutExchange exchange)
protected org.springframework.amqp.core.Queue initializeQueue(org.springframework.amqp.core.AmqpAdmin admin,
java.lang.String channelName)
protected org.springframework.integration.dispatcher.AbstractDispatcher createDispatcher()
protected java.lang.String getExchangeName()
AbstractAmqpChannelgetExchangeName in class AbstractAmqpChannelpublic void setMaxSubscribers(int maxSubscribers)
AbstractDispatcher).maxSubscribers - public boolean subscribe(org.springframework.integration.core.MessageHandler handler)
subscribe in interface org.springframework.integration.core.SubscribableChannelpublic boolean unsubscribe(org.springframework.integration.core.MessageHandler handler)
unsubscribe in interface org.springframework.integration.core.SubscribableChannelpublic void onInit()
throws java.lang.Exception
onInit in class org.springframework.integration.context.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