public class AmqpOutboundEndpoint extends AbstractAmqpOutboundEndpoint implements RabbitTemplate.ConfirmCallback, RabbitTemplate.ReturnCallback
AbstractAmqpOutboundEndpoint.CorrelationDataWrapper
AbstractReplyProducingMessageHandler.RequestHandler
messagingTemplate
EXPRESSION_PARSER, logger
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
Constructor and Description |
---|
AmqpOutboundEndpoint(AmqpTemplate amqpTemplate) |
Modifier and Type | Method and Description |
---|---|
void |
confirm(CorrelationData correlationData,
boolean ack,
String cause) |
protected void |
doStop() |
protected void |
endpointInit()
Subclasses can override to perform any additional initialization.
|
String |
getComponentType()
Subclasses may implement this method to provide component type information.
|
protected Object |
handleRequestMessage(Message<?> requestMessage)
Subclasses must implement this method to handle the request Message.
|
void |
returnedMessage(Message message,
int replyCode,
String replyText,
String exchange,
String routingKey) |
void |
setExpectReply(boolean expectReply) |
void |
setExpressionConfirmCorrelation(Expression confirmCorrelationExpression)
|
void |
setExpressionExchangeName(Expression exchangeNameExpression)
Deprecated.
|
void |
setExpressionRoutingKey(Expression routingKeyExpression)
Deprecated.
|
addDelayProperty, buildReplyMessage, buildReturnedMessage, doInit, doStart, generateCorrelationData, generateExchangeName, generateRoutingKey, getConfirmAckChannel, getConfirmCorrelationExpression, getConfirmNackChannel, getCorrelationDataGenerator, getDefaultDeliveryMode, getExchangeName, getExchangeNameExpression, getExchangeNameGenerator, getHeaderMapper, getReturnChannel, getRoutingKey, getRoutingKeyExpression, getRoutingKeyGenerator, handleConfirm, isLazyConnect, isRunning, setConfirmAckChannel, setConfirmCorrelationExpression, setConfirmCorrelationExpressionString, setConfirmNackChannel, setConnectionFactory, setDefaultDeliveryMode, setDelay, setDelayExpression, setDelayExpressionString, setExchangeName, setExchangeNameExpression, setExchangeNameExpressionString, setHeaderMapper, setLazyConnect, setReturnChannel, setRoutingKey, setRoutingKeyExpression, setRoutingKeyExpressionString, start, stop
doInvokeAdvisedRequestHandler, getRequiresReply, handleMessageInternal, hasAdviceChain, onInit, setAdviceChain, setBeanClassLoader, setRequiresReply
addNotPropagatedHeaders, createOutputMessage, getNotPropagatedHeaders, getOutputChannel, isAsync, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setNotPropagatedHeaders, setOutputChannel, setOutputChannelName, setSendTimeout, shouldCopyRequestHeaders, shouldSplitOutput
configureMetrics, getActiveCount, getActiveCountLong, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMinDuration, getOrder, getStandardDeviationDuration, handleMessage, isCountsEnabled, isLoggingEnabled, isStatsEnabled, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, 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 AmqpOutboundEndpoint(AmqpTemplate amqpTemplate)
@Deprecated public void setExpressionExchangeName(Expression exchangeNameExpression)
AbstractAmqpOutboundEndpoint.setExchangeNameExpression(org.springframework.expression.Expression)
.exchangeNameExpression
- the expression to set.@Deprecated public void setExpressionRoutingKey(Expression routingKeyExpression)
AbstractAmqpOutboundEndpoint.setRoutingKeyExpression(org.springframework.expression.Expression)
.routingKeyExpression
- the expression to set.public void setExpectReply(boolean expectReply)
@Deprecated public void setExpressionConfirmCorrelation(Expression confirmCorrelationExpression)
AbstractAmqpOutboundEndpoint.setConfirmCorrelationExpression(org.springframework.expression.Expression)
.confirmCorrelationExpression
- the expression to set.public String getComponentType()
IntegrationObjectSupport
getComponentType
in interface NamedComponent
getComponentType
in class AbstractMessageHandler
protected void endpointInit()
AbstractAmqpOutboundEndpoint
endpointInit
in class AbstractAmqpOutboundEndpoint
protected void doStop()
doStop
in class AbstractAmqpOutboundEndpoint
protected Object handleRequestMessage(Message<?> requestMessage)
AbstractReplyProducingMessageHandler
handleRequestMessage
in class AbstractReplyProducingMessageHandler
requestMessage
- The request message.null
.public void confirm(CorrelationData correlationData, boolean ack, String cause)
confirm
in interface RabbitTemplate.ConfirmCallback
public void returnedMessage(Message message, int replyCode, String replyText, String exchange, String routingKey)
returnedMessage
in interface RabbitTemplate.ReturnCallback