public abstract class AbstractAmqpChannel
extends org.springframework.integration.channel.AbstractMessageChannel
interceptors| Modifier and Type | Method and Description |
|---|---|
protected boolean |
doSend(org.springframework.messaging.Message<?> message,
long timeout) |
protected org.springframework.amqp.core.AmqpTemplate |
getAmqpTemplate() |
protected java.lang.String |
getExchangeName()
Subclasses may override this method to return an Exchange name.
|
protected AmqpHeaderMapper |
getInboundHeaderMapper() |
protected org.springframework.amqp.rabbit.core.RabbitTemplate |
getRabbitTemplate() |
protected java.lang.String |
getRoutingKey()
Subclasses may override this method to return a routing key.
|
protected boolean |
isExtractPayload() |
boolean |
isLoggingEnabled() |
void |
setDefaultDeliveryMode(org.springframework.amqp.core.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, setStatsEnabledafterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringpublic boolean isLoggingEnabled()
isLoggingEnabled in interface org.springframework.integration.support.management.IntegrationManagementisLoggingEnabled in class org.springframework.integration.channel.AbstractMessageChannelpublic void setLoggingEnabled(boolean loggingEnabled)
setLoggingEnabled in interface org.springframework.integration.support.management.IntegrationManagementsetLoggingEnabled in class org.springframework.integration.channel.AbstractMessageChannelpublic void setDefaultDeliveryMode(org.springframework.amqp.core.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 java.lang.String getExchangeName()
protected java.lang.String getRoutingKey()
protected AmqpHeaderMapper getInboundHeaderMapper()
protected org.springframework.amqp.core.AmqpTemplate getAmqpTemplate()
protected org.springframework.amqp.rabbit.core.RabbitTemplate getRabbitTemplate()
protected boolean doSend(org.springframework.messaging.Message<?> message,
long timeout)
doSend in class org.springframework.integration.channel.AbstractMessageChannel