Package org.springframework.integration.dsl

Class MessagingGatewaySpec<S extends MessagingGatewaySpec<S,G>,G extends MessagingGatewaySupport>

java.lang.Object

org.springframework.integration.dsl.IntegrationComponentSpec<S,G>

org.springframework.integration.dsl.MessagingGatewaySpec<S,G>

Type Parameters:

S - the target MessagingGatewaySpec implementation type.

G - the target MessagingGatewaySupport implementation type.

All Implemented Interfaces:

DisposableBean, FactoryBean<G>, InitializingBean, Lifecycle, Phased, SmartLifecycle

Direct Known Subclasses:

AmqpBaseInboundGatewaySpec, BaseWsInboundGatewaySpec, HttpInboundEndpointSupportSpec, JmsInboundGatewaySpec, KafkaInboundGatewaySpec, RSocketInboundGatewaySpec, TcpInboundGatewaySpec

public abstract class MessagingGatewaySpec<S extends MessagingGatewaySpec<S,G>,G extends MessagingGatewaySupport>
extends IntegrationComponentSpec<S,G>

An IntegrationComponentSpec for MessagingGatewaySupports.

Since:

5.0

Author:

Artem Bilan

Field Summary

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

logger, PARSER, target

Fields inherited from interface org.springframework.beans.factory.FactoryBean

OBJECT_TYPE_ATTRIBUTE

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor	Description
MessagingGatewaySpec(G gateway)

Method Summary

Modifier and Type	Method	Description
S	autoStartup(boolean autoStartup)	An auto-startup flag.
S	errorChannel(String errorChannelName)	An error channel name to use.
S	errorChannel(MessageChannel errorChannel)	An error channel to use.
S	errorOnTimeout(boolean errorOnTimeout)	If errorOnTimeout is true, construct an instance that will send an ErrorMessage with a MessageTimeoutException payload to the error channel if a reply is expected but none is received.
S	id(String id)	Configure the component identifier.
S	observationConvention(MessageRequestReplyReceiverObservationConvention observationConvention)	Provide a custom MessageRequestReplyReceiverObservationConvention.
S	phase(int phase)	A lifecycle phase to use.
S	replyChannel(String replyChannelName)	A reply channel name to use.
S	replyChannel(MessageChannel replyChannel)	A reply channel to use.
S	replyMapper(OutboundMessageMapper<?> replyMapper)	An OutboundMessageMapper to use.
S	replyTimeout(long replyTimeout)	A reply timeout to use.
S	requestChannel(String requestChannelName)	A request channel name to use.
S	requestChannel(MessageChannel requestChannel)	A request channel to use.
S	requestMapper(InboundMessageMapper<?> requestMapper)	An InboundMessageMapper to use.
S	requestTimeout(long requestTimeout)	A request timeout to use.
S	shouldTrack(boolean shouldTrack)	Whether component should be tracked or not by message history.

Methods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

_this, afterPropertiesSet, destroy, doGet, getId, getObject, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.beans.factory.FactoryBean

isSingleton

Constructor Details

MessagingGatewaySpec

public MessagingGatewaySpec(G gateway)

Method Details

id

public S id(@Nullable
 String id)

Description copied from class: IntegrationComponentSpec

Configure the component identifier. Used as the beanName to register the bean in the application context for this component.

Overrides:

id in class IntegrationComponentSpec<S extends MessagingGatewaySpec<S,G>,G extends MessagingGatewaySupport>

Parameters:

id - the id.

Returns:

the spec.

phase

public S phase(int phase)

A lifecycle phase to use.

Parameters:

phase - the phase.

Returns:

the spec.

See Also:

• SmartLifecycle

autoStartup

public S autoStartup(boolean autoStartup)

An auto-startup flag.

Parameters:

autoStartup - the autoStartup.

Returns:

the spec.

See Also:

• SmartLifecycle

replyChannel

public S replyChannel(MessageChannel replyChannel)

A reply channel to use.

Parameters:

replyChannel - the replyChannel.

Returns:

the spec.

See Also:

• MessagingGatewaySupport.setReplyChannel(MessageChannel)

replyChannel

public S replyChannel(String replyChannelName)

A reply channel name to use.

Parameters:

replyChannelName - the name of replyChannel.

Returns:

the spec.

See Also:

• MessagingGatewaySupport.setReplyChannelName(String)

requestChannel

public S requestChannel(MessageChannel requestChannel)

A request channel to use.

Parameters:

requestChannel - the requestChannel.

Returns:

the spec.

See Also:

• MessagingGatewaySupport.setRequestChannel(MessageChannel)

requestChannel

public S requestChannel(String requestChannelName)

A request channel name to use.

Parameters:

requestChannelName - the name of requestChannel.

Returns:

the spec.

See Also:

• MessagingGatewaySupport.setRequestChannelName(String)

errorChannel

public S errorChannel(MessageChannel errorChannel)

An error channel to use.

Parameters:

errorChannel - the errorChannel.

Returns:

the spec.

See Also:

• MessagingGatewaySupport.setErrorChannel(MessageChannel)

errorChannel

public S errorChannel(String errorChannelName)

An error channel name to use.

Parameters:

errorChannelName - the name of errorChannel.

Returns:

the spec.

See Also:

• MessagingGatewaySupport.setErrorChannelName(String)

requestTimeout

public S requestTimeout(long requestTimeout)

A request timeout to use.

Parameters:

requestTimeout - the requestTimeout.

Returns:

the spec.

See Also:

• MessagingGatewaySupport.setRequestTimeout(long)

replyTimeout

public S replyTimeout(long replyTimeout)

A reply timeout to use.

Parameters:

replyTimeout - the replyTimeout.

Returns:

the spec.

See Also:

• MessagingGatewaySupport.setReplyTimeout(long)

errorOnTimeout

public S errorOnTimeout(boolean errorOnTimeout)

If errorOnTimeout is true, construct an instance that will send an ErrorMessage with a MessageTimeoutException payload to the error channel if a reply is expected but none is received. If no error channel is configured, the MessageTimeoutException will be thrown.

Parameters:

errorOnTimeout - true to create the error message on reply timeout.

Returns:

the spec

Since:

5.2.2

See Also:

• MessagingGatewaySupport.setErrorOnTimeout(boolean)

requestMapper

public S requestMapper(InboundMessageMapper<?> requestMapper)

An InboundMessageMapper to use.

Parameters:

requestMapper - the requestMapper.

Returns:

the spec.

See Also:

• MessagingGatewaySupport.setRequestMapper(InboundMessageMapper)

replyMapper

public S replyMapper(OutboundMessageMapper<?> replyMapper)

An OutboundMessageMapper to use.

Parameters:

replyMapper - the replyMapper.

Returns:

the spec.

See Also:

• MessagingGatewaySupport.setReplyMapper(OutboundMessageMapper)

shouldTrack

public S shouldTrack(boolean shouldTrack)

Whether component should be tracked or not by message history.

Parameters:

shouldTrack - the tracking flag

Returns:

the spec.

Since:

5.0.2

See Also:

• MessagingGatewaySupport.setShouldTrack(boolean)

observationConvention

public S observationConvention(MessageRequestReplyReceiverObservationConvention observationConvention)

Provide a custom MessageRequestReplyReceiverObservationConvention.

Parameters:

observationConvention - the observation convention to use.

Returns:

the spec.

Since:

6.0.8

See Also:

• MessagingGatewaySupport.setObservationConvention(MessageRequestReplyReceiverObservationConvention)