public class AmqpOutboundEndpoint extends AbstractAmqpOutboundEndpoint implements RabbitTemplate.ConfirmCallback, RabbitTemplate.ReturnsCallback
AbstractAmqpOutboundEndpoint.CorrelationDataWrapperAbstractReplyProducingMessageHandler.RequestHandlerIntegrationManagement.ManagementOverridesmessagingTemplateEXPRESSION_PARSER, loggerHIGHEST_PRECEDENCE, LOWEST_PRECEDENCEMETER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME| 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.
|
IntegrationPatternType |
getIntegrationPatternType()
Return a pattern type this component implements.
|
RabbitTemplate |
getRabbitTemplate() |
protected Object |
handleRequestMessage(Message<?> requestMessage)
Subclasses must implement this method to handle the request Message.
|
void |
returnedMessage(ReturnedMessage returnedMessage) |
void |
setExpectReply(boolean expectReply)
Set to true if this endpoint is a gateway.
|
void |
setMultiSend(boolean multiSend)
|
void |
setWaitForConfirm(boolean waitForConfirm)
Set to true if you want to block the calling thread until a publisher confirm has
been received.
|
addDelayProperty, buildReply, buildReturnedMessage, buildReturnedMessage, doInit, doStart, generateCorrelationData, generateExchangeName, generateRoutingKey, getConfirmAckChannel, getConfirmCorrelationExpression, getConfirmNackChannel, getConfirmTimeout, getCorrelationDataGenerator, getDefaultDeliveryMode, getExchangeName, getExchangeNameExpression, getExchangeNameGenerator, getHeaderMapper, getReturnChannel, getRoutingKey, getRoutingKeyExpression, getRoutingKeyGenerator, handleConfirm, isHeadersMappedLast, isLazyConnect, isRunning, setConfirmAckChannel, setConfirmAckChannelName, setConfirmCorrelationExpression, setConfirmCorrelationExpressionString, setConfirmNackChannel, setConfirmNackChannelName, setConfirmTimeout, setConnectionFactory, setDefaultDeliveryMode, setDelay, setDelayExpression, setDelayExpressionString, setErrorMessageStrategy, setExchangeName, setExchangeNameExpression, setExchangeNameExpressionString, setHeaderMapper, setHeadersMappedLast, setLazyConnect, setReturnChannel, setRoutingKey, setRoutingKeyExpression, setRoutingKeyExpressionString, start, stopdoInvokeAdvisedRequestHandler, getBeanClassLoader, getRequiresReply, handleMessageInternal, hasAdviceChain, onInit, setAdviceChain, setBeanClassLoader, setRequiresReplyaddNotPropagatedHeaders, createOutputMessage, getNotPropagatedHeaders, getOutputChannel, isAsync, messageBuilderForReply, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setNotPropagatedHeaders, setOutputChannel, setOutputChannelName, setSendTimeout, shouldCopyRequestHeaders, shouldSplitOutput, updateNotPropagatedHeadershandleMessage, onComplete, onError, onNext, onSubscribebuildSendTimer, destroy, getManagedName, getManagedType, getMetricsCaptor, getOrder, getOverrides, isLoggingEnabled, registerMetricsCaptor, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrackafterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitdelegate, returnedMessagegetThisAsgetBeanName, getComponentNamepublic AmqpOutboundEndpoint(AmqpTemplate amqpTemplate)
public void setExpectReply(boolean expectReply)
expectReply - true for a gateway.public void setWaitForConfirm(boolean waitForConfirm)
waitForConfirm - true to block until the confirmation or timeout is received.AbstractAmqpOutboundEndpoint.setConfirmTimeout(long),
setMultiSend(boolean)public String getComponentType()
IntegrationObjectSupportgetComponentType in interface NamedComponentgetComponentType in class MessageHandlerSupportpublic void setMultiSend(boolean multiSend)
Iterable of Message, send
the messages in a single invocation of the template (same channel) and optionally
wait for the confirms or die or perform all sends within a transaction (existing or
new).multiSend - true to send multiple messages.setWaitForConfirm(boolean)public IntegrationPatternType getIntegrationPatternType()
IntegrationPatterngetIntegrationPatternType in interface IntegrationPatterngetIntegrationPatternType in class AbstractReplyProducingMessageHandlerIntegrationPatternType this component implements.public RabbitTemplate getRabbitTemplate()
getRabbitTemplate in class AbstractAmqpOutboundEndpointprotected void endpointInit()
AbstractAmqpOutboundEndpointendpointInit in class AbstractAmqpOutboundEndpointprotected void doStop()
doStop in class AbstractAmqpOutboundEndpointprotected Object handleRequestMessage(Message<?> requestMessage)
AbstractReplyProducingMessageHandlerhandleRequestMessage in class AbstractReplyProducingMessageHandlerrequestMessage - The request message.null.public void confirm(CorrelationData correlationData, boolean ack, String cause)
confirm in interface RabbitTemplate.ConfirmCallbackpublic void returnedMessage(ReturnedMessage returnedMessage)
returnedMessage in interface RabbitTemplate.ReturnCallbackreturnedMessage in interface RabbitTemplate.ReturnsCallback