Package org.springframework.integration.dsl

Class MessageProducerSpec<S extends MessageProducerSpec<S,P>,P extends MessageProducerSupport>

java.lang.Object

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

org.springframework.integration.dsl.MessageProducerSpec<S,P>

Type Parameters:

S - the target MessageProducerSpec implementation type.

P - the target MessageProducerSupport implementation type.

All Implemented Interfaces:

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

Direct Known Subclasses:

AmqpBaseInboundChannelAdapterSpec, DebeziumMessageProducerSpec, ImapIdleChannelAdapterSpec, JmsMessageDrivenChannelAdapterSpec, KafkaMessageDrivenChannelAdapterSpec, MongoDbChangeStreamMessageProducerSpec, TailAdapterSpec, TcpInboundChannelAdapterSpec, UdpInboundChannelAdapterSpec, ZeroMqMessageProducerSpec

public abstract class MessageProducerSpec<S extends MessageProducerSpec<S,P>,P extends MessageProducerSupport>
extends IntegrationComponentSpec<S,P>

An IntegrationComponentSpec for MessageProducers.

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
MessageProducerSpec(P producer)

Method Summary

Modifier and Type	Method	Description
S	autoStartup(boolean autoStartup)
S	errorChannel(String errorChannel)	Configure the bean name of the MessageChannel to which error messages will be sent.
S	errorChannel(MessageChannel errorChannel)	Configure the MessageChannel to which error messages will be sent.
S	errorMessageStrategy(ErrorMessageStrategy errorMessageStrategy)	Set an ErrorMessageStrategy to use to build an error message when a exception occurs.
S	id(String id)	Configure the component identifier.
S	observationConvention(MessageReceiverObservationConvention observationConvention)	Provide a custom MessageReceiverObservationConvention.
S	outputChannel(String outputChannel)	Specify the bean name of the outputChannel for the MessageProducer.
S	outputChannel(MessageChannel outputChannel)	Specify the outputChannel for the MessageProducer.
S	phase(int phase)
S	sendTimeout(long sendTimeout)	Configure the default timeout value to use for send operations.
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

MessageProducerSpec

public MessageProducerSpec(@Nullable
 P producer)

Method Details

id

public S id(@Nullable
 String id)

Configure the component identifier. Used as the beanName to register the bean in the application context for this component. Configure the message producer's bean name.

Overrides:

id in class IntegrationComponentSpec<S extends MessageProducerSpec<S,P>,P extends MessageProducerSupport>

Parameters:

id - the id.

Returns:

the spec.

phase

public S phase(int phase)

Parameters:

phase - the phase.

Returns:

the spec.

See Also:

• SmartLifecycle

autoStartup

public S autoStartup(boolean autoStartup)

Parameters:

autoStartup - the autoStartup.

Returns:

the spec.

See Also:

• SmartLifecycle

outputChannel

public S outputChannel(MessageChannel outputChannel)

Specify the outputChannel for the MessageProducer.

Parameters:

outputChannel - the outputChannel.

Returns:

the spec.

See Also:

• MessageProducerSupport.setOutputChannel(MessageChannel)

outputChannel

public S outputChannel(String outputChannel)

Specify the bean name of the outputChannel for the MessageProducer.

Parameters:

outputChannel - the outputChannel bean name.

Returns:

the spec.

See Also:

• MessageProducerSupport.setOutputChannelName(String)

errorChannel

public S errorChannel(MessageChannel errorChannel)

Configure the MessageChannel to which error messages will be sent.

Parameters:

errorChannel - the errorChannel.

Returns:

the spec.

See Also:

• MessageProducerSupport.setErrorChannel(MessageChannel)

errorChannel

public S errorChannel(String errorChannel)

Configure the bean name of the MessageChannel to which error messages will be sent.

Parameters:

errorChannel - the errorChannel bean name.

Returns:

the spec.

See Also:

• MessageProducerSupport.setErrorChannelName(String)

sendTimeout

public S sendTimeout(long sendTimeout)

Configure the default timeout value to use for send operations. May be overridden for individual messages.

Parameters:

sendTimeout - the send timeout in milliseconds

Returns:

the spec.

Since:

5.0.2

See Also:

• MessageProducerSupport.setSendTimeout(long)

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:

• MessageProducerSupport.setShouldTrack(boolean)

errorMessageStrategy

public S errorMessageStrategy(ErrorMessageStrategy errorMessageStrategy)

Set an ErrorMessageStrategy to use to build an error message when a exception occurs.

Parameters:

errorMessageStrategy - the ErrorMessageStrategy.

Returns:

the spec.

Since:

5.0.2

See Also:

• MessageProducerSupport.setErrorMessageStrategy(ErrorMessageStrategy)

observationConvention

public S observationConvention(MessageReceiverObservationConvention observationConvention)

Provide a custom MessageReceiverObservationConvention.

Parameters:

observationConvention - the observation convention to use.

Returns:

the spec.

Since:

6.0.8

See Also:

• MessageProducerSupport.setObservationConvention(MessageReceiverObservationConvention)