org.springframework.integration.core

Interface MessageProducer

All Known Implementing Classes:

AbstractAmqpOutboundEndpoint, AbstractCorrelatingMessageHandler, AbstractHttpRequestExecutingMessageHandler, AbstractInternetProtocolReceivingChannelAdapter, AbstractMessageProducingHandler, AbstractMessageSplitter, AbstractMqttMessageDrivenChannelAdapter, AbstractRemoteFileOutboundGateway, AbstractReplyProducingMessageHandler, AbstractReplyProducingPostProcessingMessageHandler, AbstractWebServiceOutboundGateway, AbstractXmppConnectionAwareEndpoint, AggregatingMessageHandler, AmqpInboundChannelAdapter, AmqpOutboundEndpoint, ApacheCommonsFileTailingMessageProducer, ApplicationEventListeningMessageProducer, AsyncAmqpOutboundGateway, BarrierMessageHandler, BridgeHandler, CacheListeningMessageProducer, ChatMessageListeningEndpoint, ContentEnricher, ContinuousQueryMessageProducer, DefaultMessageSplitter, DelayHandler, ExpressionEvaluatingSplitter, ExpressionMessageProducerSupport, FileSplitter, FileTailingMessageProducerSupport, FileWritingMessageHandler, FluxAggregatorMessageHandler, FtpOutboundGateway, GatewayMessageHandler, HttpRequestExecutingMessageHandler, ImapIdleChannelAdapter, JdbcOutboundGateway, JmsMessageDrivenEndpoint, JmsOutboundGateway, JpaOutboundGateway, KafkaMessageDrivenChannelAdapter, KafkaProducerMessageHandler, MarshallingWebServiceOutboundGateway, MessageFilter, MessageHandlerChain, MessageProducerSupport, MessageTransformingHandler, MethodInvokingSplitter, MockMessageHandler, MongoDbChangeStreamMessageProducer, MongoDbOutboundGateway, MqttPahoMessageDrivenChannelAdapter, MulticastReceivingChannelAdapter, NotificationListeningMessageProducer, OperationInvokingMessageHandler, OSDelegatingFileTailingMessageProducer, PresenceListeningEndpoint, ReactiveMessageSourceProducer, ReactiveRedisStreamMessageProducer, RedisInboundChannelAdapter, RedisOutboundGateway, RedisQueueMessageDrivenEndpoint, RedisQueueOutboundGateway, ReplyProducingMessageHandlerWrapper, ResequencingMessageHandler, RmiOutboundGateway, RSocketOutboundGateway, ScatterGatherHandler, ServiceActivatingHandler, SftpOutboundGateway, SimpleWebServiceOutboundGateway, StompInboundChannelAdapter, StoredProcOutboundGateway, SyslogReceivingChannelAdapterSupport, TcpOutboundGateway, TcpReceivingChannelAdapter, TcpSyslogReceivingChannelAdapter, UdpSyslogReceivingChannelAdapter, UnicastReceivingChannelAdapter, WebFluxRequestExecutingMessageHandler, WebSocketInboundChannelAdapter, XPathMessageSplitter, ZeroMqMessageProducer

public interface MessageProducer

Base interface for any component that is capable of sending messages to a MessageChannel.

Since:

2.0

Author:

Mark Fisher, Artem Bilan

Method Summary

Modifier and Type	Method and Description
MessageChannel	getOutputChannel() Return the the output channel.
void	setOutputChannel(MessageChannel outputChannel) Specify the MessageChannel to which produced Messages should be sent.
default void	setOutputChannelName(String outputChannel) Specify the bean name of the MessageChannel to which produced Messages should be sent.

Method Detail

setOutputChannel

void setOutputChannel(MessageChannel outputChannel)

Specify the MessageChannel to which produced Messages should be sent.

Parameters:

outputChannel - The output channel.

setOutputChannelName

default void setOutputChannelName(String outputChannel)

Specify the bean name of the MessageChannel to which produced Messages should be sent.

Parameters:

outputChannel - The output channel bean name.

Since:

5.1.2

getOutputChannel

@Nullable
MessageChannel getOutputChannel()

Return the the output channel.

Returns:

the channel.

Since:

4.3