public class AmqpOutboundEndpoint extends AbstractAmqpOutboundEndpoint implements org.springframework.amqp.rabbit.core.RabbitTemplate.ConfirmCallback, org.springframework.amqp.rabbit.core.RabbitTemplate.ReturnsCallback
AbstractAmqpOutboundEndpoint.CorrelationDataWrappermessagingTemplateEXPRESSION_PARSER, logger| Constructor and Description |
|---|
AmqpOutboundEndpoint(org.springframework.amqp.core.AmqpTemplate amqpTemplate) |
| Modifier and Type | Method and Description |
|---|---|
void |
confirm(org.springframework.amqp.rabbit.connection.CorrelationData correlationData,
boolean ack,
java.lang.String cause) |
protected void |
doStop() |
protected void |
endpointInit()
Subclasses can override to perform any additional initialization.
|
java.lang.String |
getComponentType() |
org.springframework.integration.IntegrationPatternType |
getIntegrationPatternType() |
org.springframework.amqp.rabbit.core.RabbitTemplate |
getRabbitTemplate() |
protected java.lang.Object |
handleRequestMessage(org.springframework.messaging.Message<?> requestMessage) |
void |
returnedMessage(org.springframework.amqp.core.ReturnedMessage returnedMessage) |
void |
setExpectReply(boolean expectReply)
Set to true if this endpoint is a gateway.
|
void |
setMultiSend(boolean multiSend)
If true, and the message payload is an
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). |
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, returnedMessagepublic AmqpOutboundEndpoint(org.springframework.amqp.core.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 java.lang.String getComponentType()
getComponentType in interface org.springframework.integration.support.context.NamedComponentgetComponentType in class org.springframework.integration.handler.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 org.springframework.integration.IntegrationPatternType getIntegrationPatternType()
getIntegrationPatternType in interface org.springframework.integration.IntegrationPatterngetIntegrationPatternType in class org.springframework.integration.handler.AbstractReplyProducingMessageHandlerpublic org.springframework.amqp.rabbit.core.RabbitTemplate getRabbitTemplate()
getRabbitTemplate in class AbstractAmqpOutboundEndpointprotected void endpointInit()
AbstractAmqpOutboundEndpointendpointInit in class AbstractAmqpOutboundEndpointprotected void doStop()
doStop in class AbstractAmqpOutboundEndpointprotected java.lang.Object handleRequestMessage(org.springframework.messaging.Message<?> requestMessage)
handleRequestMessage in class org.springframework.integration.handler.AbstractReplyProducingMessageHandlerpublic void confirm(org.springframework.amqp.rabbit.connection.CorrelationData correlationData,
boolean ack,
java.lang.String cause)
confirm in interface org.springframework.amqp.rabbit.core.RabbitTemplate.ConfirmCallbackpublic void returnedMessage(org.springframework.amqp.core.ReturnedMessage returnedMessage)
returnedMessage in interface org.springframework.amqp.rabbit.core.RabbitTemplate.ReturnCallbackreturnedMessage in interface org.springframework.amqp.rabbit.core.RabbitTemplate.ReturnsCallback