org.springframework.integration.dsl.amqp

Class AmqpBaseOutboundEndpointSpec<S extends AmqpBaseOutboundEndpointSpec<S,E>,E extends org.springframework.integration.amqp.outbound.AbstractAmqpOutboundEndpoint>

java.lang.Object

org.springframework.integration.dsl.core.IntegrationComponentSpec<S,H>

org.springframework.integration.dsl.core.MessageHandlerSpec<S,E>

org.springframework.integration.dsl.amqp.AmqpBaseOutboundEndpointSpec<S,E>

Type Parameters:

S - the target AmqpBaseOutboundEndpointSpec implementation type.

E - the target AbstractAmqpOutboundEndpoint implementation type.

All Implemented Interfaces:

org.springframework.beans.factory.FactoryBean<E>

Direct Known Subclasses:

AmqpAsyncOutboundGatewaySpec, AmqpOutboundEndpointSpec

public abstract class AmqpBaseOutboundEndpointSpec<S extends AmqpBaseOutboundEndpointSpec<S,E>,E extends org.springframework.integration.amqp.outbound.AbstractAmqpOutboundEndpoint>
extends MessageHandlerSpec<S,E>

The base MessageHandlerSpec for AbstractAmqpOutboundEndpoints.

Since:

1.2

Author:

Artem Bilan

Field Summary

Fields

Modifier and Type	Field and Description
protected org.springframework.integration.amqp.support.DefaultAmqpHeaderMapper	headerMapper

Fields inherited from class org.springframework.integration.dsl.core.IntegrationComponentSpec

logger, PARSER, target

Constructor Summary

Constructors

Constructor and Description
AmqpBaseOutboundEndpointSpec()

Method Summary

Modifier and Type	Method and Description
S	confirmAckChannel(org.springframework.messaging.MessageChannel ackChannel)
S	confirmCorrelationExpression(org.springframework.expression.Expression confirmCorrelationExpression)
S	confirmCorrelationExpression(java.lang.String confirmCorrelationExpression)
S	confirmCorrelationFunction(Function<org.springframework.messaging.Message<?>,java.lang.Object> confirmCorrelationFunction)
S	confirmNackChannel(org.springframework.messaging.MessageChannel nackChannel)
S	defaultDeliveryMode(org.springframework.amqp.core.MessageDeliveryMode defaultDeliveryMode)
S	exchangeName(java.lang.String exchangeName)
S	exchangeNameExpression(org.springframework.expression.Expression exchangeNameExpression)
S	exchangeNameExpression(java.lang.String exchangeNameExpression)
S	exchangeNameFunction(Function<org.springframework.messaging.Message<?>,java.lang.String> exchangeNameFunction)
S	headerMapper(org.springframework.integration.amqp.support.AmqpHeaderMapper headerMapper)
S	mappedReplyHeaders(java.lang.String... headers)
S	mappedRequestHeaders(java.lang.String... headers)
S	returnChannel(org.springframework.messaging.MessageChannel returnChannel)
S	routingKey(java.lang.String routingKey)
S	routingKeyExpression(org.springframework.expression.Expression routingKeyExpression)
S	routingKeyExpression(java.lang.String routingKeyExpression)
S	routingKeyFunction(Function<org.springframework.messaging.Message<?>,java.lang.String> routingKeyFunction)

Methods inherited from class org.springframework.integration.dsl.core.IntegrationComponentSpec

_this, doGet, get, getId, getObject, getObjectType, id, isSingleton

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

headerMapper

protected final org.springframework.integration.amqp.support.DefaultAmqpHeaderMapper headerMapper

Constructor Detail

AmqpBaseOutboundEndpointSpec

public AmqpBaseOutboundEndpointSpec()

Method Detail

headerMapper

public S headerMapper(org.springframework.integration.amqp.support.AmqpHeaderMapper headerMapper)

defaultDeliveryMode

public S defaultDeliveryMode(org.springframework.amqp.core.MessageDeliveryMode defaultDeliveryMode)

routingKey

public S routingKey(java.lang.String routingKey)

routingKeyExpression

public S routingKeyExpression(java.lang.String routingKeyExpression)

routingKeyFunction

public S routingKeyFunction(Function<org.springframework.messaging.Message<?>,java.lang.String> routingKeyFunction)

routingKeyExpression

public S routingKeyExpression(org.springframework.expression.Expression routingKeyExpression)

returnChannel

public S returnChannel(org.springframework.messaging.MessageChannel returnChannel)

confirmAckChannel

public S confirmAckChannel(org.springframework.messaging.MessageChannel ackChannel)

exchangeName

public S exchangeName(java.lang.String exchangeName)

exchangeNameExpression

public S exchangeNameExpression(java.lang.String exchangeNameExpression)

exchangeNameFunction

public S exchangeNameFunction(Function<org.springframework.messaging.Message<?>,java.lang.String> exchangeNameFunction)

exchangeNameExpression

public S exchangeNameExpression(org.springframework.expression.Expression exchangeNameExpression)

confirmNackChannel

public S confirmNackChannel(org.springframework.messaging.MessageChannel nackChannel)

confirmCorrelationExpression

public S confirmCorrelationExpression(java.lang.String confirmCorrelationExpression)

confirmCorrelationFunction

public S confirmCorrelationFunction(Function<org.springframework.messaging.Message<?>,java.lang.Object> confirmCorrelationFunction)

confirmCorrelationExpression

public S confirmCorrelationExpression(org.springframework.expression.Expression confirmCorrelationExpression)

mappedRequestHeaders

public S mappedRequestHeaders(java.lang.String... headers)

mappedReplyHeaders

public S mappedReplyHeaders(java.lang.String... headers)