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:

org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.FactoryBean<P>, org.springframework.beans.factory.InitializingBean

Direct Known Subclasses:

AmqpBaseInboundChannelAdapterSpec, ImapIdleChannelAdapterSpec, JmsMessageDrivenChannelAdapterSpec, TailAdapterSpec, TcpInboundChannelAdapterSpec, UdpInboundChannelAdapterSpec

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

Constructor Summary

Constructors

Constructor and Description
MessageProducerSpec(P producer)

Method Summary

Modifier and Type	Method and Description
S	autoStartup(boolean autoStartup)
S	errorChannel(org.springframework.messaging.MessageChannel errorChannel) Configure the MessageChannel to which error messages will be sent.
S	errorChannel(java.lang.String errorChannel) Configure the bean name of 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(java.lang.String id) Configure the component identifier.
S	outputChannel(org.springframework.messaging.MessageChannel outputChannel) Specify the outputChannel for the MessageProducer
S	outputChannel(java.lang.String outputChannel) Specify the bean name of 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, get, getId, getObject, getObjectType, isSingleton

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageProducerSpec

public MessageProducerSpec(P producer)

Method Detail

id

public S id(java.lang.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(org.springframework.messaging.MessageChannel outputChannel)

Specify the outputChannel for the MessageProducer

Parameters:

outputChannel - the outputChannel.

Returns:

the spec.

See Also:

MessageProducerSupport.setOutputChannel(MessageChannel)

outputChannel

public S outputChannel(java.lang.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(org.springframework.messaging.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(java.lang.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)