org.springframework.integration.dsl.jms

Class JmsOutboundGatewaySpec

java.lang.Object

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

org.springframework.integration.dsl.core.MessageHandlerSpec<JmsOutboundGatewaySpec,org.springframework.integration.jms.JmsOutboundGateway>

org.springframework.integration.dsl.jms.JmsOutboundGatewaySpec

All Implemented Interfaces:

org.springframework.beans.factory.FactoryBean<org.springframework.integration.jms.JmsOutboundGateway>

public class JmsOutboundGatewaySpec
extends MessageHandlerSpec<JmsOutboundGatewaySpec,org.springframework.integration.jms.JmsOutboundGateway>

A MessageHandlerSpec for a JmsOutboundGateway.

Author:

Artem Bilan

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	JmsOutboundGatewaySpec.ReplyContainerSpec An IntegrationComponentSpec for JmsOutboundGateway.ReplyContainerProperties.

Field Summary

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

logger, PARSER, target

Method Summary

Modifier and Type	Method and Description
JmsOutboundGatewaySpec	correlationKey(java.lang.String correlationKey)
JmsOutboundGatewaySpec	deliveryPersistent(boolean deliveryPersistent)
JmsOutboundGatewaySpec	destinationResolver(org.springframework.jms.support.destination.DestinationResolver destinationResolver)
JmsOutboundGatewaySpec	explicitQosEnabled(boolean explicitQosEnabled)
JmsOutboundGatewaySpec	extractReplyPayload(boolean extractPayload)
JmsOutboundGatewaySpec	extractRequestPayload(boolean extractPayload)
JmsOutboundGatewaySpec	headerMapper(org.springframework.integration.jms.JmsHeaderMapper headerMapper)
JmsOutboundGatewaySpec	jmsMessageConverter(org.springframework.jms.support.converter.MessageConverter messageConverter)
JmsOutboundGatewaySpec	priority(int priority) Default priority.
JmsOutboundGatewaySpec	receiveTimeout(long receiveTimeout)
JmsOutboundGatewaySpec	replyContainer() Configure a reply container with default properties.
JmsOutboundGatewaySpec	replyContainer(Consumer<JmsOutboundGatewaySpec.ReplyContainerSpec> configurer) Configure a reply container with a reply container specification determined by invoking the Consumer callback with a JmsOutboundGatewaySpec.ReplyContainerSpec.
JmsOutboundGatewaySpec	replyDestination(javax.jms.Destination destination)
<P> JmsOutboundGatewaySpec	replyDestination(Function<org.springframework.messaging.Message<P>,?> destinationFunction) Configure a Function that will be invoked at run time to determine the destination from which a reply will be received.
JmsOutboundGatewaySpec	replyDestination(java.lang.String destination)
JmsOutboundGatewaySpec	replyDestinationExpression(java.lang.String destination)
JmsOutboundGatewaySpec	replyPubSubDomain(boolean pubSubDomain)
JmsOutboundGatewaySpec	requestDestination(javax.jms.Destination destination)
<P> JmsOutboundGatewaySpec	requestDestination(Function<org.springframework.messaging.Message<P>,?> destinationFunction) Configure a Function that will be invoked at run time to determine the destination to which a message will be sent.
JmsOutboundGatewaySpec	requestDestination(java.lang.String destination)
JmsOutboundGatewaySpec	requestDestinationExpression(java.lang.String destination)
JmsOutboundGatewaySpec	requestPubSubDomain(boolean pubSubDomain)
JmsOutboundGatewaySpec	timeToLive(long timeToLive)

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

Method Detail

extractRequestPayload

public JmsOutboundGatewaySpec extractRequestPayload(boolean extractPayload)

Parameters:

extractPayload - the extractPayload.

Returns:

the current JmsOutboundGatewaySpec.

See Also:

JmsOutboundGateway.setExtractRequestPayload(boolean)

extractReplyPayload

public JmsOutboundGatewaySpec extractReplyPayload(boolean extractPayload)

Parameters:

extractPayload - the extractPayload.

Returns:

the current JmsOutboundGatewaySpec.

See Also:

JmsOutboundGateway.setExtractReplyPayload(boolean)

headerMapper

public JmsOutboundGatewaySpec headerMapper(org.springframework.integration.jms.JmsHeaderMapper headerMapper)

Parameters:

headerMapper - the headerMapper.

Returns:

the current JmsOutboundGatewaySpec.

See Also:

JmsOutboundGateway.setHeaderMapper(JmsHeaderMapper)

requestDestination

public JmsOutboundGatewaySpec requestDestination(javax.jms.Destination destination)

Parameters:

destination - the destination.

Returns:

the current JmsOutboundGatewaySpec.

See Also:

JmsOutboundGateway.setRequestDestination(Destination)

requestDestination

public JmsOutboundGatewaySpec requestDestination(java.lang.String destination)

Parameters:

destination - the destination name.

Returns:

the current JmsOutboundGatewaySpec.

See Also:

JmsOutboundGateway.setRequestDestinationName(String)

requestDestinationExpression

public JmsOutboundGatewaySpec requestDestinationExpression(java.lang.String destination)

Parameters:

destination - the destination expression.

Returns:

the current JmsOutboundGatewaySpec.

See Also:

JmsOutboundGateway.setRequestDestinationExpression(org.springframework.expression.Expression)

requestDestination

public <P> JmsOutboundGatewaySpec requestDestination(Function<org.springframework.messaging.Message<P>,?> destinationFunction)

Configure a Function that will be invoked at run time to determine the destination to which a message will be sent. Typically used with a Java 8 Lambda expression:

 .<Foo>destination(m -> m.getPayload().getState())
 
 

Type Parameters:

P - the expected payload type.

Parameters:

destinationFunction - the destination function.

Returns:

the current JmsOutboundGatewaySpec.

See Also:

JmsOutboundGateway.setRequestDestinationExpression(org.springframework.expression.Expression), FunctionExpression

replyDestination

public JmsOutboundGatewaySpec replyDestination(javax.jms.Destination destination)

Parameters:

destination - the destination.

Returns:

the current JmsOutboundGatewaySpec.

See Also:

JmsOutboundGateway.setReplyDestination(Destination)

replyDestination

public JmsOutboundGatewaySpec replyDestination(java.lang.String destination)

Parameters:

destination - the destination name.

Returns:

the current JmsOutboundGatewaySpec.

See Also:

JmsOutboundGateway.setReplyDestinationName(String)

replyDestinationExpression

public JmsOutboundGatewaySpec replyDestinationExpression(java.lang.String destination)

Parameters:

destination - the destination expression.

Returns:

the current JmsOutboundGatewaySpec.

See Also:

JmsOutboundGateway.setReplyDestinationExpression(org.springframework.expression.Expression)

replyDestination

public <P> JmsOutboundGatewaySpec replyDestination(Function<org.springframework.messaging.Message<P>,?> destinationFunction)

Configure a Function that will be invoked at run time to determine the destination from which a reply will be received. Typically used with a Java 8 Lambda expression:

 .<Foo>replyDestination(m -> m.getPayload().getState())
 
 

Type Parameters:

P - the expected payload type.

Parameters:

destinationFunction - the destination function.

Returns:

the current JmsOutboundGatewaySpec.

See Also:

JmsOutboundGateway.setReplyDestinationExpression(org.springframework.expression.Expression), FunctionExpression

destinationResolver

public JmsOutboundGatewaySpec destinationResolver(org.springframework.jms.support.destination.DestinationResolver destinationResolver)

Parameters:

destinationResolver - the destinationResolver.

Returns:

the current JmsOutboundGatewaySpec.

See Also:

JmsOutboundGateway.setDestinationResolver(DestinationResolver)

jmsMessageConverter

public JmsOutboundGatewaySpec jmsMessageConverter(org.springframework.jms.support.converter.MessageConverter messageConverter)

Parameters:

messageConverter - the messageConverter.

Returns:

the current JmsOutboundGatewaySpec.

See Also:

JmsOutboundGateway.setMessageConverter(MessageConverter)

correlationKey

public JmsOutboundGatewaySpec correlationKey(java.lang.String correlationKey)

Parameters:

correlationKey - the correlationKey

Returns:

the current JmsOutboundGatewaySpec.

See Also:

JmsOutboundGateway.setCorrelationKey(String)

requestPubSubDomain

public JmsOutboundGatewaySpec requestPubSubDomain(boolean pubSubDomain)

Parameters:

pubSubDomain - the pubSubDomain

Returns:

the current JmsOutboundGatewaySpec.

See Also:

JmsOutboundGateway.setReplyPubSubDomain(boolean)

replyPubSubDomain

public JmsOutboundGatewaySpec replyPubSubDomain(boolean pubSubDomain)

Parameters:

pubSubDomain - the pubSubDomain

Returns:

the current JmsOutboundGatewaySpec.

See Also:

JmsOutboundGateway.setRequestPubSubDomain(boolean)

deliveryPersistent

public JmsOutboundGatewaySpec deliveryPersistent(boolean deliveryPersistent)

Parameters:

deliveryPersistent - the deliveryPersistent.

Returns:

the current JmsOutboundGatewaySpec.

See Also:

JmsOutboundGateway.setDeliveryPersistent(boolean)

priority

public JmsOutboundGatewaySpec priority(int priority)

Default priority. May be overridden at run time with a message priority header.

Parameters:

priority - the priority.

Returns:

the current JmsOutboundGatewaySpec.

See Also:

JmsOutboundGateway.setPriority(int)

timeToLive

public JmsOutboundGatewaySpec timeToLive(long timeToLive)

Parameters:

timeToLive - the timeToLive.

Returns:

the current JmsOutboundGatewaySpec.

See Also:

JmsOutboundGateway.setTimeToLive(long)

receiveTimeout

public JmsOutboundGatewaySpec receiveTimeout(long receiveTimeout)

Parameters:

receiveTimeout - the receiveTimeout.

Returns:

the current JmsOutboundGatewaySpec.

See Also:

JmsOutboundGateway.setReceiveTimeout(long)

explicitQosEnabled

public JmsOutboundGatewaySpec explicitQosEnabled(boolean explicitQosEnabled)

Parameters:

explicitQosEnabled - the explicitQosEnabled.

Returns:

the current JmsOutboundGatewaySpec.

See Also:

JmsOutboundGateway.setExplicitQosEnabled(boolean)

replyContainer

public JmsOutboundGatewaySpec replyContainer()

Configure a reply container with default properties.

Returns:

the current JmsOutboundGatewaySpec.

replyContainer

public JmsOutboundGatewaySpec replyContainer(Consumer<JmsOutboundGatewaySpec.ReplyContainerSpec> configurer)

Configure a reply container with a reply container specification determined by invoking the Consumer callback with a JmsOutboundGatewaySpec.ReplyContainerSpec.

Parameters:

configurer - the configurer.

Returns:

the current JmsOutboundGatewaySpec.