Class JmsOutboundGatewaySpec
java.lang.Object
org.springframework.beans.factory.config.AbstractFactoryBean<T>
org.springframework.integration.dsl.IntegrationComponentSpec<S,H>
org.springframework.integration.dsl.MessageHandlerSpec<JmsOutboundGatewaySpec,JmsOutboundGateway>
org.springframework.integration.jms.dsl.JmsOutboundGatewaySpec
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanClassLoaderAware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.DisposableBean,org.springframework.beans.factory.FactoryBean<JmsOutboundGateway>,org.springframework.beans.factory.InitializingBean,org.springframework.context.Lifecycle,org.springframework.context.Phased,org.springframework.context.SmartLifecycle
public class JmsOutboundGatewaySpec extends org.springframework.integration.dsl.MessageHandlerSpec<JmsOutboundGatewaySpec,JmsOutboundGateway>
A
MessageHandlerSpec for a JmsOutboundGateway.- Since:
- 5.0
-
Nested Class Summary
Nested Classes Modifier and Type Class Description classJmsOutboundGatewaySpec.ReplyContainerSpecAnIntegrationComponentSpecforJmsOutboundGateway.ReplyContainerProperties. -
Field Summary
-
Constructor Summary
Constructors Modifier Constructor Description protectedJmsOutboundGatewaySpec(javax.jms.ConnectionFactory connectionFactory) -
Method Summary
Modifier and Type Method Description JmsOutboundGatewaySpeccorrelationKey(java.lang.String correlationKey)JmsOutboundGatewaySpecdeliveryPersistent(boolean deliveryPersistent)JmsOutboundGatewaySpecdestinationResolver(org.springframework.jms.support.destination.DestinationResolver destinationResolver)JmsOutboundGatewaySpecexplicitQosEnabled(boolean explicitQosEnabled)JmsOutboundGatewaySpecextractReplyPayload(boolean extractPayload)JmsOutboundGatewaySpecextractRequestPayload(boolean extractPayload)JmsOutboundGatewaySpecheaderMapper(JmsHeaderMapper headerMapper)JmsOutboundGatewaySpecjmsMessageConverter(org.springframework.jms.support.converter.MessageConverter messageConverter)JmsOutboundGatewaySpecpriority(int priority)Default priority.JmsOutboundGatewaySpecreceiveTimeout(long receiveTimeout)JmsOutboundGatewaySpecreplyContainer()Configure a reply container with default properties.JmsOutboundGatewaySpecreplyContainer(java.util.function.Consumer<JmsOutboundGatewaySpec.ReplyContainerSpec> configurer)Configure a reply container with a reply container specification determined by invoking theConsumercallback with aJmsOutboundGatewaySpec.ReplyContainerSpec.JmsOutboundGatewaySpecreplyDestination(java.lang.String destination)<P> JmsOutboundGatewaySpecreplyDestination(java.util.function.Function<org.springframework.messaging.Message<P>,?> destinationFunction)Configure aFunctionthat will be invoked at run time to determine the destination from which a reply will be received.JmsOutboundGatewaySpecreplyDestination(javax.jms.Destination destination)JmsOutboundGatewaySpecreplyDestinationExpression(java.lang.String destination)JmsOutboundGatewaySpecreplyPubSubDomain(boolean pubSubDomain)JmsOutboundGatewaySpecrequestDestination(java.lang.String destination)<P> JmsOutboundGatewaySpecrequestDestination(java.util.function.Function<org.springframework.messaging.Message<P>,?> destinationFunction)Configure aFunctionthat will be invoked at runtime to determine the destination to which a message will be sent.JmsOutboundGatewaySpecrequestDestination(javax.jms.Destination destination)JmsOutboundGatewaySpecrequestDestinationExpression(java.lang.String destination)JmsOutboundGatewaySpecrequestPubSubDomain(boolean pubSubDomain)JmsOutboundGatewaySpectimeToLive(long timeToLive)Methods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stop
-
Constructor Details
-
JmsOutboundGatewaySpec
protected JmsOutboundGatewaySpec(javax.jms.ConnectionFactory connectionFactory)
-
-
Method Details
-
extractRequestPayload
- Parameters:
extractPayload- the extractPayload.- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
JmsOutboundGateway.setExtractRequestPayload(boolean)
-
extractReplyPayload
- Parameters:
extractPayload- the extractPayload.- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
JmsOutboundGateway.setExtractReplyPayload(boolean)
-
headerMapper
- Parameters:
headerMapper- the headerMapper.- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
JmsOutboundGateway.setHeaderMapper(JmsHeaderMapper)
-
requestDestination
- Parameters:
destination- the destination.- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
JmsOutboundGateway.setRequestDestination(Destination)
-
requestDestination
- Parameters:
destination- the destination name.- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
JmsOutboundGateway.setRequestDestinationName(String)
-
requestDestinationExpression
- Parameters:
destination- the destination expression.- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
JmsOutboundGateway.setRequestDestinationExpression(org.springframework.expression.Expression)
-
requestDestination
public <P> JmsOutboundGatewaySpec requestDestination(java.util.function.Function<org.springframework.messaging.Message<P>,?> destinationFunction)Configure aFunctionthat 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())- 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
- Parameters:
destination- the destination.- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
JmsOutboundGateway.setReplyDestination(Destination)
-
replyDestination
- Parameters:
destination- the destination name.- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
JmsOutboundGateway.setReplyDestinationName(String)
-
replyDestinationExpression
- Parameters:
destination- the destination expression.- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
JmsOutboundGateway.setReplyDestinationExpression(org.springframework.expression.Expression)
-
replyDestination
public <P> JmsOutboundGatewaySpec replyDestination(java.util.function.Function<org.springframework.messaging.Message<P>,?> destinationFunction)Configure aFunctionthat 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
- Parameters:
correlationKey- the correlationKey- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
JmsOutboundGateway.setCorrelationKey(String)
-
requestPubSubDomain
- Parameters:
pubSubDomain- the pubSubDomain- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
JmsOutboundGateway.setReplyPubSubDomain(boolean)
-
replyPubSubDomain
- Parameters:
pubSubDomain- the pubSubDomain- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
JmsOutboundGateway.setRequestPubSubDomain(boolean)
-
deliveryPersistent
- Parameters:
deliveryPersistent- the deliveryPersistent.- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
JmsOutboundGateway.setDeliveryPersistent(boolean)
-
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.setDefaultPriority(int)
-
timeToLive
- Parameters:
timeToLive- the timeToLive.- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
JmsOutboundGateway.setTimeToLive(long)
-
receiveTimeout
- Parameters:
receiveTimeout- the receiveTimeout.- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
JmsOutboundGateway.setReceiveTimeout(long)
-
explicitQosEnabled
- Parameters:
explicitQosEnabled- the explicitQosEnabled.- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
JmsOutboundGateway.setExplicitQosEnabled(boolean)
-
replyContainer
Configure a reply container with default properties.- Returns:
- the current
JmsOutboundGatewaySpec.
-
replyContainer
public JmsOutboundGatewaySpec replyContainer(java.util.function.Consumer<JmsOutboundGatewaySpec.ReplyContainerSpec> configurer)Configure a reply container with a reply container specification determined by invoking theConsumercallback with aJmsOutboundGatewaySpec.ReplyContainerSpec.- Parameters:
configurer- the configurer.- Returns:
- the current
JmsOutboundGatewaySpec.
-