public abstract class AbstractAmqpChannel extends AbstractMessageChannel
AbstractMessageChannel.ChannelInterceptorList
interceptors
EXPRESSION_PARSER, logger
INDEFINITE_TIMEOUT
Modifier and Type | Method and Description |
---|---|
protected boolean |
doSend(Message<?> message,
long timeout)
Subclasses must implement this method.
|
protected AmqpTemplate |
getAmqpTemplate() |
protected String |
getExchangeName()
Subclasses may override this method to return an Exchange name.
|
protected AmqpHeaderMapper |
getInboundHeaderMapper() |
protected RabbitTemplate |
getRabbitTemplate() |
protected String |
getRoutingKey()
Subclasses may override this method to return a routing key.
|
protected boolean |
isExtractPayload() |
boolean |
isLoggingEnabled() |
void |
setDefaultDeliveryMode(MessageDeliveryMode defaultDeliveryMode)
Set the delivery mode to use if the message has no
"amqp_deliveryMode"
header and the message property was not set by the
MessagePropertiesConverter . |
void |
setExtractPayload(boolean extractPayload)
Set to true to extract the payload and map the headers; otherwise
the entire message is converted and sent.
|
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, setCountsEnabled, setDatatypes, setInterceptors, setMessageConverter, setShouldTrack, setStatsEnabled
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, 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
public void setDefaultDeliveryMode(MessageDeliveryMode defaultDeliveryMode)
MessagePropertiesConverter
.defaultDeliveryMode
- the default delivery mode.public void setExtractPayload(boolean extractPayload)
extractPayload
- true to extract and map.protected boolean isExtractPayload()
setExtractPayload(boolean)
protected String getExchangeName()
protected String getRoutingKey()
protected AmqpHeaderMapper getInboundHeaderMapper()
protected AmqpTemplate getAmqpTemplate()
protected RabbitTemplate getRabbitTemplate()
protected boolean doSend(Message<?> message, long timeout)
AbstractMessageChannel
doSend
in class AbstractMessageChannel
message
- The message.timeout
- The timeout.