org.springframework.integration.amqp.dsl

Class AmqpBaseOutboundEndpointSpec<S extends AmqpBaseOutboundEndpointSpec<S,E>,E extends AbstractAmqpOutboundEndpoint>

java.lang.Object

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

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

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

Type Parameters:

S - the target AmqpBaseOutboundEndpointSpec implementation type.

E - the target AbstractAmqpOutboundEndpoint implementation type.

All Implemented Interfaces:

FactoryBean<E>

Direct Known Subclasses:

AmqpAsyncOutboundGatewaySpec, AmqpOutboundEndpointSpec

public abstract class AmqpBaseOutboundEndpointSpec<S extends AmqpBaseOutboundEndpointSpec<S,E>,E extends AbstractAmqpOutboundEndpoint>
extends MessageHandlerSpec<S,E>

The base MessageHandlerSpec for AbstractAmqpOutboundEndpoints.

Since:

5.0

Author:

Artem Bilan

Field Summary

Fields

Modifier and Type	Field and Description
protected DefaultAmqpHeaderMapper	headerMapper

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

logger, PARSER, target

Constructor Summary

Constructors

Constructor and Description
AmqpBaseOutboundEndpointSpec()

Method Summary

Modifier and Type	Method and Description
S	confirmAckChannel(MessageChannel ackChannel)
S	confirmCorrelationExpression(Expression confirmCorrelationExpression)
S	confirmCorrelationExpression(String confirmCorrelationExpression)
S	confirmCorrelationFunction(java.util.function.Function<Message<?>,Object> confirmCorrelationFunction)
S	confirmNackChannel(MessageChannel nackChannel)
S	defaultDeliveryMode(MessageDeliveryMode defaultDeliveryMode)
S	exchangeName(String exchangeName)
S	exchangeNameExpression(Expression exchangeNameExpression)
S	exchangeNameExpression(String exchangeNameExpression)
S	exchangeNameFunction(java.util.function.Function<Message<?>,String> exchangeNameFunction)
S	headerMapper(AmqpHeaderMapper headerMapper)
S	headersMappedLast(boolean headersLast)
S	mappedReplyHeaders(String... headers)
S	mappedRequestHeaders(String... headers)
S	returnChannel(MessageChannel returnChannel)
S	routingKey(String routingKey)
S	routingKeyExpression(Expression routingKeyExpression)
S	routingKeyExpression(String routingKeyExpression)
S	routingKeyFunction(java.util.function.Function<Message<?>,String> routingKeyFunction)

Methods inherited from class org.springframework.integration.dsl.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 DefaultAmqpHeaderMapper headerMapper

Constructor Detail

AmqpBaseOutboundEndpointSpec

public AmqpBaseOutboundEndpointSpec()

Method Detail

headerMapper

public S headerMapper(AmqpHeaderMapper headerMapper)

defaultDeliveryMode

public S defaultDeliveryMode(MessageDeliveryMode defaultDeliveryMode)

routingKey

public S routingKey(String routingKey)

routingKeyExpression

public S routingKeyExpression(String routingKeyExpression)

routingKeyFunction

public S routingKeyFunction(java.util.function.Function<Message<?>,String> routingKeyFunction)

routingKeyExpression

public S routingKeyExpression(Expression routingKeyExpression)

returnChannel

public S returnChannel(MessageChannel returnChannel)

confirmAckChannel

public S confirmAckChannel(MessageChannel ackChannel)

exchangeName

public S exchangeName(String exchangeName)

exchangeNameExpression

public S exchangeNameExpression(String exchangeNameExpression)

exchangeNameFunction

public S exchangeNameFunction(java.util.function.Function<Message<?>,String> exchangeNameFunction)

exchangeNameExpression

public S exchangeNameExpression(Expression exchangeNameExpression)

confirmNackChannel

public S confirmNackChannel(MessageChannel nackChannel)

confirmCorrelationExpression

public S confirmCorrelationExpression(String confirmCorrelationExpression)

confirmCorrelationFunction

public S confirmCorrelationFunction(java.util.function.Function<Message<?>,Object> confirmCorrelationFunction)

confirmCorrelationExpression

public S confirmCorrelationExpression(Expression confirmCorrelationExpression)

mappedRequestHeaders

public S mappedRequestHeaders(String... headers)

mappedReplyHeaders

public S mappedReplyHeaders(String... headers)

headersMappedLast

public S headersMappedLast(boolean headersLast)

Parameters:

headersLast - true to map headers last.

Returns:

the spec.

See Also:

AbstractAmqpOutboundEndpoint.setHeadersMappedLast(boolean)