Interface MessageProducer

All Known Implementing Classes:
AbstractAmqpOutboundEndpoint, AbstractCorrelatingMessageHandler, AbstractHazelcastMessageProducer, AbstractHttpRequestExecutingMessageHandler, AbstractInternetProtocolReceivingChannelAdapter, AbstractInternetProtocolReceivingChannelAdapter, AbstractMessageProducingHandler, AbstractMessageSplitter, AbstractMqttMessageDrivenChannelAdapter, AbstractRemoteFileOutboundGateway, AbstractReplyProducingMessageHandler, AbstractReplyProducingPostProcessingMessageHandler, AbstractWebServiceOutboundGateway, AbstractWebServiceOutboundGateway, AbstractXmppConnectionAwareEndpoint, AggregatingMessageHandler, AmqpClientMessageHandler, AmqpClientMessageProducer, AmqpInboundChannelAdapter, AmqpOutboundEndpoint, ApacheCommonsFileTailingMessageProducer, ApplicationEventListeningMessageProducer, AsyncAmqpOutboundGateway, BarrierMessageHandler, BridgeHandler, CamelMessageHandler, CassandraMessageHandler, ChatMessageListeningEndpoint, ContentEnricher, DebeziumMessageProducer, DefaultMessageSplitter, DelayHandler, ExpressionEvaluatingSplitter, ExpressionMessageProducerSupport, FileSplitter, FileTailingMessageProducerSupport, FileWritingMessageHandler, FileWritingMessageHandler, FluxAggregatorMessageHandler, FtpOutboundGateway, FtpOutboundGateway, GatewayMessageHandler, GraphQlMessageHandler, HazelcastClusterMonitorMessageProducer, HazelcastContinuousQueryMessageProducer, HazelcastEventDrivenMessageProducer, HttpRequestExecutingMessageHandler, ImapIdleChannelAdapter, ImapIdleChannelAdapter, JdbcOutboundGateway, JdbcOutboundGateway, JmsMessageDrivenEndpoint, JmsMessageDrivenEndpoint, JmsOutboundGateway, JmsOutboundGateway, JpaOutboundGateway, KafkaMessageDrivenChannelAdapter, KafkaProducerMessageHandler, MarshallingWebServiceOutboundGateway, MarshallingWebServiceOutboundGateway, MessageFilter, MessageHandlerChain, MessageProducerSupport, MessageTransformingHandler, MethodInvokingSplitter, MockMessageHandler, MongoDbChangeStreamMessageProducer, MongoDbOutboundGateway, MqttPahoMessageDrivenChannelAdapter, Mqttv5PahoMessageDrivenChannelAdapter, MulticastReceivingChannelAdapter, MulticastReceivingChannelAdapter, NotificationListeningMessageProducer, NotificationListeningMessageProducer, OperationInvokingMessageHandler, OperationInvokingMessageHandler, OSDelegatingFileTailingMessageProducer, PresenceListeningEndpoint, ReactiveMessageSourceProducer, ReactiveRedisStreamMessageProducer, RedisInboundChannelAdapter, RedisOutboundGateway, RedisQueueMessageDrivenEndpoint, RedisQueueOutboundGateway, ReplyProducingMessageHandlerWrapper, ResequencingMessageHandler, RSocketOutboundGateway, ScatterGatherHandler, ServiceActivatingHandler, SftpOutboundGateway, SftpOutboundGateway, SimpleWebServiceOutboundGateway, SimpleWebServiceOutboundGateway, SmbOutboundGateway, StompInboundChannelAdapter, StoredProcOutboundGateway, StoredProcOutboundGateway, SyslogReceivingChannelAdapterSupport, TcpOutboundGateway, TcpOutboundGateway, TcpReceivingChannelAdapter, TcpReceivingChannelAdapter, TcpSyslogReceivingChannelAdapter, UdpSyslogReceivingChannelAdapter, UnicastReceivingChannelAdapter, UnicastReceivingChannelAdapter, UnZipResultSplitter, 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 Details

    • 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 output channel.
      Returns:
      the channel.
      Since:
      4.3