public class AmqpOutboundEndpointSpec extends MessageHandlerSpec<AmqpOutboundEndpointSpec,org.springframework.integration.amqp.outbound.AmqpOutboundEndpoint>
id, logger, PARSER, target
Modifier and Type | Method and Description |
---|---|
AmqpOutboundEndpointSpec |
confirmAckChannel(org.springframework.messaging.MessageChannel ackChannel) |
AmqpOutboundEndpointSpec |
confirmCorrelationExpression(java.lang.String confirmCorrelationExpression) |
AmqpOutboundEndpointSpec |
confirmNackChannel(org.springframework.messaging.MessageChannel nackChannel) |
AmqpOutboundEndpointSpec |
defaultDeliveryMode(org.springframework.amqp.core.MessageDeliveryMode defaultDeliveryMode) |
protected org.springframework.integration.amqp.outbound.AmqpOutboundEndpoint |
doGet() |
AmqpOutboundEndpointSpec |
exchangeName(java.lang.String exchangeName) |
AmqpOutboundEndpointSpec |
exchangeNameExpression(java.lang.String exchangeNameExpression) |
AmqpOutboundEndpointSpec |
headerMapper(org.springframework.integration.amqp.support.AmqpHeaderMapper headerMapper) |
AmqpOutboundEndpointSpec |
mappedReplyHeaders(java.lang.String... headers) |
AmqpOutboundEndpointSpec |
mappedRequestHeaders(java.lang.String... headers) |
AmqpOutboundEndpointSpec |
returnChannel(org.springframework.messaging.MessageChannel returnChannel) |
AmqpOutboundEndpointSpec |
routingKey(java.lang.String routingKey) |
AmqpOutboundEndpointSpec |
routingKeyExpression(java.lang.String routingKeyExpression) |
_this, get, getId, id
public AmqpOutboundEndpointSpec headerMapper(org.springframework.integration.amqp.support.AmqpHeaderMapper headerMapper)
public AmqpOutboundEndpointSpec routingKey(java.lang.String routingKey)
public AmqpOutboundEndpointSpec defaultDeliveryMode(org.springframework.amqp.core.MessageDeliveryMode defaultDeliveryMode)
public AmqpOutboundEndpointSpec exchangeName(java.lang.String exchangeName)
public AmqpOutboundEndpointSpec routingKeyExpression(java.lang.String routingKeyExpression)
public AmqpOutboundEndpointSpec returnChannel(org.springframework.messaging.MessageChannel returnChannel)
public AmqpOutboundEndpointSpec confirmAckChannel(org.springframework.messaging.MessageChannel ackChannel)
public AmqpOutboundEndpointSpec exchangeNameExpression(java.lang.String exchangeNameExpression)
public AmqpOutboundEndpointSpec confirmNackChannel(org.springframework.messaging.MessageChannel nackChannel)
public AmqpOutboundEndpointSpec confirmCorrelationExpression(java.lang.String confirmCorrelationExpression)
public AmqpOutboundEndpointSpec mappedRequestHeaders(java.lang.String... headers)
public AmqpOutboundEndpointSpec mappedReplyHeaders(java.lang.String... headers)
protected org.springframework.integration.amqp.outbound.AmqpOutboundEndpoint doGet()
doGet
in class IntegrationComponentSpec<AmqpOutboundEndpointSpec,org.springframework.integration.amqp.outbound.AmqpOutboundEndpoint>