public class PublishSubscribeAmqpChannel extends AbstractAmqpChannel
AbstractMessageChannel.ChannelInterceptorListIntegrationManagement.ManagementOverridesinterceptorsEXPRESSION_PARSER, loggerMETER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME| Constructor and Description |
|---|
PublishSubscribeAmqpChannel(java.lang.String channelName,
org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer container,
org.springframework.amqp.core.AmqpTemplate amqpTemplate)
Construct an instance with the supplied name, container and template; default header
mappers will be used if the message is mapped.
|
PublishSubscribeAmqpChannel(java.lang.String channelName,
org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer container,
org.springframework.amqp.core.AmqpTemplate amqpTemplate,
AmqpHeaderMapper outboundMapper,
AmqpHeaderMapper inboundMapper)
Construct an instance with the supplied name, container and template; default header
mappers will be used if the message is mapped.
|
| Modifier and Type | Method and Description |
|---|---|
protected AbstractDispatcher |
createDispatcher() |
void |
destroy() |
protected void |
doDeclares() |
protected java.lang.String |
getExchangeName()
Subclasses may override this method to return an Exchange name.
|
int |
getPhase() |
boolean |
isAutoStartup() |
boolean |
isRunning() |
protected java.lang.String |
obtainQueueName(java.lang.String channelName) |
void |
onInit()
Subclasses may implement this for initialization logic.
|
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.messaging.MessageHandler handler) |
boolean |
unsubscribe(org.springframework.messaging.MessageHandler handler) |
doSend, getAdmin, getAmqpTemplate, getConnectionFactory, getInboundHeaderMapper, getRabbitTemplate, getRoutingKey, isExtractPayload, isLoggingEnabled, onClose, onCreate, setAdmin, setConnectionFactory, setDefaultDeliveryMode, setExtractPayload, setHeadersMappedLast, setLoggingEnabledaddInterceptor, addInterceptor, configureMetrics, getChannelInterceptors, getComponentType, getErrorRate, getFullChannelName, getInterceptors, getMaxSendDuration, getMeanErrorRate, getMeanErrorRatio, getMeanSendDuration, getMeanSendRate, getMetrics, getMetricsCaptor, getMinSendDuration, getOverrides, getSendCount, getSendCountLong, getSendDuration, getSendErrorCount, getSendErrorCountLong, getSendRate, getStandardDeviationSendDuration, getTimeSinceLastSend, isCountsEnabled, isStatsEnabled, registerMetricsCaptor, removeInterceptor, removeInterceptor, reset, send, send, setCountsEnabled, setDatatypes, setInterceptors, setMessageConverter, setShouldTrack, setStatsEnabledafterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitonShutDowngetComponentNamepublic PublishSubscribeAmqpChannel(java.lang.String channelName,
org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer container,
org.springframework.amqp.core.AmqpTemplate amqpTemplate)
channelName - the channel name.container - the container.amqpTemplate - the template.AbstractAmqpChannel.setExtractPayload(boolean)public PublishSubscribeAmqpChannel(java.lang.String channelName,
org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer container,
org.springframework.amqp.core.AmqpTemplate amqpTemplate,
AmqpHeaderMapper outboundMapper,
AmqpHeaderMapper inboundMapper)
channelName - the channel name.container - the container.amqpTemplate - the templateoutboundMapper - the outbound mapper.inboundMapper - the inbound mapper.AbstractAmqpChannel.setExtractPayload(boolean)public void setExchange(org.springframework.amqp.core.FanoutExchange exchange)
exchange - The fanout exchange.protected java.lang.String getExchangeName()
AbstractAmqpChannelgetExchangeName in class AbstractAmqpChannelprotected java.lang.String obtainQueueName(java.lang.String channelName)
protected AbstractDispatcher createDispatcher()
protected void doDeclares()
doDeclares in class AbstractAmqpChannelpublic void setMaxSubscribers(int maxSubscribers)
AbstractDispatcher).maxSubscribers - The maximum number of subscribers allowed.public boolean subscribe(org.springframework.messaging.MessageHandler handler)
subscribe in interface org.springframework.messaging.SubscribableChannelpublic boolean unsubscribe(org.springframework.messaging.MessageHandler handler)
unsubscribe in interface org.springframework.messaging.SubscribableChannelpublic void onInit()
throws java.lang.Exception
IntegrationObjectSupportonInit in class AbstractAmqpChanneljava.lang.Exception - Any exception.public boolean isAutoStartup()
isAutoStartup in interface org.springframework.context.SmartLifecyclepublic int getPhase()
getPhase in interface org.springframework.context.PhasedgetPhase in interface org.springframework.context.SmartLifecyclepublic 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.DisposableBeandestroy in class AbstractAmqpChanneljava.lang.Exception