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 ClassesModifier and TypeClassDescriptionclassAnIntegrationComponentSpecforJmsOutboundGateway.ReplyContainerProperties. -
Field Summary
Fields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
PARSER, targetFields inherited from class org.springframework.beans.factory.config.AbstractFactoryBean
loggerFields inherited from interface org.springframework.beans.factory.FactoryBean
OBJECT_TYPE_ATTRIBUTEFields inherited from interface org.springframework.context.SmartLifecycle
DEFAULT_PHASE -
Constructor Summary
ConstructorsModifierConstructorDescriptionprotectedJmsOutboundGatewaySpec(jakarta.jms.ConnectionFactory connectionFactory) -
Method Summary
Modifier and TypeMethodDescriptioncorrelationKey(String correlationKey) deliveryPersistent(boolean deliveryPersistent) destinationResolver(org.springframework.jms.support.destination.DestinationResolver destinationResolver) explicitQosEnabled(boolean explicitQosEnabled) extractReplyPayload(boolean extractPayload) extractRequestPayload(boolean extractPayload) headerMapper(JmsHeaderMapper headerMapper) jmsMessageConverter(org.springframework.jms.support.converter.MessageConverter messageConverter) priority(int priority) Default priority.receiveTimeout(long receiveTimeout) Configure a reply container with default properties.Configure a reply container with a reply container specification determined by invoking theConsumercallback with aJmsOutboundGatewaySpec.ReplyContainerSpec.replyDestination(jakarta.jms.Destination destination) replyDestination(String destination) replyDestination(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.replyDestinationExpression(String destination) replyPubSubDomain(boolean pubSubDomain) requestDestination(jakarta.jms.Destination destination) requestDestination(String destination) requestDestination(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.requestDestinationExpression(String destination) requestPubSubDomain(boolean pubSubDomain) timeToLive(long timeToLive) Methods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stopMethods inherited from class org.springframework.beans.factory.config.AbstractFactoryBean
afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton
-
Constructor Details
-
JmsOutboundGatewaySpec
protected JmsOutboundGatewaySpec(jakarta.jms.ConnectionFactory connectionFactory)
-
-
Method Details
-
extractRequestPayload
- Parameters:
extractPayload- the extractPayload.- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
-
extractReplyPayload
- Parameters:
extractPayload- the extractPayload.- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
-
headerMapper
- Parameters:
headerMapper- the headerMapper.- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
-
requestDestination
- Parameters:
destination- the destination.- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
-
requestDestination
- Parameters:
destination- the destination name.- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
-
requestDestinationExpression
- Parameters:
destination- the destination expression.- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
-
requestDestination
public <P> JmsOutboundGatewaySpec requestDestination(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:
-
replyDestination
- Parameters:
destination- the destination.- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
-
replyDestination
- Parameters:
destination- the destination name.- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
-
replyDestinationExpression
- Parameters:
destination- the destination expression.- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
-
replyDestination
public <P> JmsOutboundGatewaySpec replyDestination(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:
-
destinationResolver
public JmsOutboundGatewaySpec destinationResolver(org.springframework.jms.support.destination.DestinationResolver destinationResolver) - Parameters:
destinationResolver- the destinationResolver.- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
-
jmsMessageConverter
public JmsOutboundGatewaySpec jmsMessageConverter(org.springframework.jms.support.converter.MessageConverter messageConverter) - Parameters:
messageConverter- the messageConverter.- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
-
correlationKey
- Parameters:
correlationKey- the correlationKey- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
-
requestPubSubDomain
- Parameters:
pubSubDomain- the pubSubDomain- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
-
replyPubSubDomain
- Parameters:
pubSubDomain- the pubSubDomain- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
-
deliveryPersistent
- Parameters:
deliveryPersistent- the deliveryPersistent.- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
-
priority
Default priority. May be overridden at run time with a message priority header.- Parameters:
priority- the priority.- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
-
timeToLive
- Parameters:
timeToLive- the timeToLive.- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
-
receiveTimeout
- Parameters:
receiveTimeout- the receiveTimeout.- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
-
explicitQosEnabled
- Parameters:
explicitQosEnabled- the explicitQosEnabled.- Returns:
- the current
JmsOutboundGatewaySpec. - See Also:
-
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 theConsumercallback with aJmsOutboundGatewaySpec.ReplyContainerSpec.- Parameters:
configurer- the configurer.- Returns:
- the current
JmsOutboundGatewaySpec.
-