public abstract class AbstractAmqpChannel extends AbstractMessageChannel
AbstractMessageChannel.ChannelInterceptorList
interceptors
logger
INDEFINITE_TIMEOUT
Modifier and Type | Method and Description |
---|---|
protected boolean |
doSend(Message<?> message,
long timeout)
Subclasses must implement this method.
|
protected String |
getExchangeName()
Subclasses may override this method to return an Exchange name.
|
protected 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, 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
getComponentName
public boolean isLoggingEnabled()
isLoggingEnabled
in interface IntegrationManagement
isLoggingEnabled
in class AbstractMessageChannel
public void setLoggingEnabled(boolean loggingEnabled)
setLoggingEnabled
in interface IntegrationManagement
setLoggingEnabled
in class AbstractMessageChannel
protected String getExchangeName()
protected String getRoutingKey()
protected boolean doSend(Message<?> message, long timeout)
AbstractMessageChannel
doSend
in class AbstractMessageChannel
message
- The message.timeout
- The timeout.