public class PointToPointSubscribableAmqpChannel extends AbstractAmqpChannel
AbstractMessageChannel.ChannelInterceptorList
interceptors
logger
INDEFINITE_TIMEOUT
Constructor and Description |
---|
PointToPointSubscribableAmqpChannel(String channelName,
SimpleMessageListenerContainer container,
AmqpTemplate amqpTemplate) |
Modifier and Type | Method and Description |
---|---|
protected AbstractDispatcher |
createDispatcher() |
void |
destroy() |
protected AmqpAdmin |
getAdmin() |
protected ConnectionFactory |
getConnectionFactory() |
int |
getPhase() |
protected String |
getRoutingKey()
Subclasses may override this method to return a routing key.
|
boolean |
isAutoStartup() |
boolean |
isRunning() |
protected String |
obtainQueueName(AmqpAdmin admin,
String channelName) |
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(String queueName)
Provide a Queue name to be used.
|
void |
start() |
void |
stop() |
void |
stop(Runnable callback) |
boolean |
subscribe(MessageHandler handler) |
boolean |
unsubscribe(MessageHandler handler) |
doSend, getExchangeName, isLoggingEnabled, setLoggingEnabled
addInterceptor, addInterceptor, configureMetrics, getChannelInterceptors, getComponentType, getErrorRate, getFullChannelName, getInterceptors, getMaxSendDuration, getMeanErrorRate, getMeanErrorRatio, getMeanSendDuration, getMeanSendRate, getMetrics, getMinSendDuration, getSendCount, getSendCountLong, getSendDuration, getSendErrorCount, getSendErrorCountLong, getSendRate, getStandardDeviationSendDuration, getTimeSinceLastSend, isCountsEnabled, isStatsEnabled, removeInterceptor, removeInterceptor, reset, send, send, setConversionService, setCountsEnabled, setDatatypes, setInterceptors, setMessageConverter, setShouldTrack, setStatsEnabled
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setMessageBuilderFactory, setTaskScheduler, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
send, send
getComponentName
public PointToPointSubscribableAmqpChannel(String channelName, SimpleMessageListenerContainer container, AmqpTemplate amqpTemplate)
public void setQueueName(String queueName)
queueName
- The queue name.protected AbstractDispatcher createDispatcher()
protected String getRoutingKey()
AbstractAmqpChannel
getRoutingKey
in class AbstractAmqpChannel
public void setMaxSubscribers(int maxSubscribers)
AbstractDispatcher
).maxSubscribers
- The maximum number of subscribers allowed.protected AmqpAdmin getAdmin()
protected ConnectionFactory getConnectionFactory()
public boolean subscribe(MessageHandler handler)
subscribe
in interface SubscribableChannel
public boolean unsubscribe(MessageHandler handler)
unsubscribe
in interface SubscribableChannel
public void onInit() throws Exception
IntegrationObjectSupport
onInit
in class AbstractMessageChannel
Exception
- Any exception.public boolean isAutoStartup()
isAutoStartup
in interface SmartLifecycle
public void stop(Runnable callback)
stop
in interface SmartLifecycle
public void destroy() throws Exception
destroy
in interface DisposableBean
Exception