public class JmsOutboundGatewaySpec extends MessageHandlerSpec<JmsOutboundGatewaySpec,JmsOutboundGateway>
MessageHandlerSpec
for a JmsOutboundGateway
.Modifier and Type | Class and Description |
---|---|
class |
JmsOutboundGatewaySpec.ReplyContainerSpec
An
IntegrationComponentSpec for JmsOutboundGateway.ReplyContainerProperties . |
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(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(java.util.function.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(java.util.function.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(java.util.function.Function<org.springframework.messaging.Message<P>,?> destinationFunction)
Configure a
Function that will be invoked at runtime 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, afterPropertiesSet, destroy, doGet, get, getId, getObject, getObjectType, id
public 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(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(java.util.function.Function<org.springframework.messaging.Message<P>,?> destinationFunction)
Function
that will be invoked at runtime 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)
,
FunctionExpression
public 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(java.util.function.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)
,
FunctionExpression
public 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(java.util.function.Consumer<JmsOutboundGatewaySpec.ReplyContainerSpec> configurer)
Consumer
callback with a JmsOutboundGatewaySpec.ReplyContainerSpec
.configurer
- the configurer.JmsOutboundGatewaySpec
.