public abstract class AbstractAmqpChannel extends AbstractMessageChannel
AbstractMessageChannel.ChannelInterceptorListinterceptorslogger| Modifier and Type | Method and Description |
|---|---|
protected boolean |
doSend(org.springframework.messaging.Message<?> message,
long timeout)
Subclasses must implement this method.
|
protected java.lang.String |
getExchangeName()
Subclasses may override this method to return an Exchange name.
|
protected java.lang.String |
getRoutingKey()
Subclasses may override this method to return a routing key.
|
boolean |
isLoggingEnabled() |
void |
setLoggingEnabled(boolean loggingEnabled) |
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, onInit, removeInterceptor, removeInterceptor, reset, send, send, setConversionService, setCountsEnabled, setDatatypes, setInterceptors, setMessageConverter, setShouldTrack, setStatsEnabledafterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setMessageBuilderFactory, setTaskScheduler, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetComponentNamepublic boolean isLoggingEnabled()
isLoggingEnabled in interface IntegrationManagementisLoggingEnabled in class AbstractMessageChannelpublic void setLoggingEnabled(boolean loggingEnabled)
setLoggingEnabled in interface IntegrationManagementsetLoggingEnabled in class AbstractMessageChannelprotected java.lang.String getExchangeName()
protected java.lang.String getRoutingKey()
protected boolean doSend(org.springframework.messaging.Message<?> message,
long timeout)
AbstractMessageChanneldoSend in class AbstractMessageChannelmessage - The message.timeout - The timeout.