public class JmsOutboundGatewaySpec extends MessageHandlerSpec<JmsOutboundGatewaySpec,org.springframework.integration.jms.JmsOutboundGateway>
MessageHandlerSpec for a JmsOutboundGateway.| Modifier and Type | Class and Description |
|---|---|
class |
JmsOutboundGatewaySpec.ReplyContainerSpec
An
IntegrationComponentSpec for JmsOutboundGateway.ReplyContainerProperties. |
id, logger, PARSER, target| 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) |
_this, doGet, get, getId, getObject, getObjectType, id, isSingletonpublic JmsOutboundGatewaySpec extractRequestPayload(boolean extractPayload)
extractPayload - the extractPayload.JmsOutboundGatewaySpec.JmsOutboundGateway.setExtractRequestPayload(boolean)public JmsOutboundGatewaySpec extractReplyPayload(boolean extractPayload)
extractPayload - the extractPayload.JmsOutboundGatewaySpec.JmsOutboundGateway.setExtractReplyPayload(boolean)public JmsOutboundGatewaySpec headerMapper(org.springframework.integration.jms.JmsHeaderMapper headerMapper)
headerMapper - the headerMapper.JmsOutboundGatewaySpec.JmsOutboundGateway.setHeaderMapper(JmsHeaderMapper)public JmsOutboundGatewaySpec requestDestination(javax.jms.Destination destination)
destination - the destination.JmsOutboundGatewaySpec.JmsOutboundGateway.setRequestDestination(Destination)public JmsOutboundGatewaySpec requestDestination(java.lang.String destination)
destination - the destination name.JmsOutboundGatewaySpec.JmsOutboundGateway.setRequestDestinationName(String)public JmsOutboundGatewaySpec requestDestinationExpression(java.lang.String destination)
destination - the destination expression.JmsOutboundGatewaySpec.JmsOutboundGateway.setRequestDestinationExpression(org.springframework.expression.Expression)public <P> JmsOutboundGatewaySpec requestDestination(Function<org.springframework.messaging.Message<P>,?> destinationFunction)
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())
P - the expected payload type.destinationFunction - the destination function.JmsOutboundGatewaySpec.JmsOutboundGateway.setRequestDestinationExpression(org.springframework.expression.Expression),
FunctionExpressionpublic JmsOutboundGatewaySpec replyDestination(javax.jms.Destination destination)
destination - the destination.JmsOutboundGatewaySpec.JmsOutboundGateway.setReplyDestination(Destination)public JmsOutboundGatewaySpec replyDestination(java.lang.String destination)
destination - the destination name.JmsOutboundGatewaySpec.JmsOutboundGateway.setReplyDestinationName(String)public JmsOutboundGatewaySpec replyDestinationExpression(java.lang.String destination)
destination - the destination expression.JmsOutboundGatewaySpec.JmsOutboundGateway.setReplyDestinationExpression(org.springframework.expression.Expression)public <P> JmsOutboundGatewaySpec replyDestination(Function<org.springframework.messaging.Message<P>,?> destinationFunction)
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())
P - the expected payload type.destinationFunction - the destination function.JmsOutboundGatewaySpec.JmsOutboundGateway.setReplyDestinationExpression(org.springframework.expression.Expression),
FunctionExpressionpublic JmsOutboundGatewaySpec destinationResolver(org.springframework.jms.support.destination.DestinationResolver destinationResolver)
destinationResolver - the destinationResolver.JmsOutboundGatewaySpec.JmsOutboundGateway.setDestinationResolver(DestinationResolver)public JmsOutboundGatewaySpec jmsMessageConverter(org.springframework.jms.support.converter.MessageConverter messageConverter)
messageConverter - the messageConverter.JmsOutboundGatewaySpec.JmsOutboundGateway.setMessageConverter(MessageConverter)public JmsOutboundGatewaySpec correlationKey(java.lang.String correlationKey)
correlationKey - the correlationKeyJmsOutboundGatewaySpec.JmsOutboundGateway.setCorrelationKey(String)public JmsOutboundGatewaySpec requestPubSubDomain(boolean pubSubDomain)
pubSubDomain - the pubSubDomainJmsOutboundGatewaySpec.JmsOutboundGateway.setReplyPubSubDomain(boolean)public JmsOutboundGatewaySpec replyPubSubDomain(boolean pubSubDomain)
pubSubDomain - the pubSubDomainJmsOutboundGatewaySpec.JmsOutboundGateway.setRequestPubSubDomain(boolean)public JmsOutboundGatewaySpec deliveryPersistent(boolean deliveryPersistent)
deliveryPersistent - the deliveryPersistent.JmsOutboundGatewaySpec.JmsOutboundGateway.setDeliveryPersistent(boolean)public JmsOutboundGatewaySpec priority(int priority)
priority - the priority.JmsOutboundGatewaySpec.JmsOutboundGateway.setPriority(int)public JmsOutboundGatewaySpec timeToLive(long timeToLive)
timeToLive - the timeToLive.JmsOutboundGatewaySpec.JmsOutboundGateway.setTimeToLive(long)public JmsOutboundGatewaySpec receiveTimeout(long receiveTimeout)
receiveTimeout - the receiveTimeout.JmsOutboundGatewaySpec.JmsOutboundGateway.setReceiveTimeout(long)public JmsOutboundGatewaySpec explicitQosEnabled(boolean explicitQosEnabled)
explicitQosEnabled - the explicitQosEnabled.JmsOutboundGatewaySpec.JmsOutboundGateway.setExplicitQosEnabled(boolean)public JmsOutboundGatewaySpec replyContainer()
JmsOutboundGatewaySpec.public JmsOutboundGatewaySpec replyContainer(Consumer<JmsOutboundGatewaySpec.ReplyContainerSpec> configurer)
Consumer callback with a JmsOutboundGatewaySpec.ReplyContainerSpec.configurer - the configurer.JmsOutboundGatewaySpec.