Uses of Interface
org.springframework.integration.core.MessageProducer

Packages that use MessageProducer

Package	Description
org.springframework.integration.aggregator	Provides classes related to message aggregation.
org.springframework.integration.amqp.inbound	Provides classes supporting inbound endpoints.
org.springframework.integration.amqp.outbound	Provides classes supporting outbound endpoints.
org.springframework.integration.camel.outbound	Provides classes for Apache Camel outbound channel adapters.
org.springframework.integration.cassandra.outbound	Provides classes supporting Cassandra outbound endpoints.
org.springframework.integration.debezium.inbound	Provides classes for the Debezium inbound channel adapters.
org.springframework.integration.dsl	Root package of the Spring Integration Java DSL.
org.springframework.integration.endpoint	Provides core classes related to Endpoints.
org.springframework.integration.event.inbound	Provides classes supporting inbound endpoints.
org.springframework.integration.file	Base package for File support.
org.springframework.integration.file.remote.gateway	Provides classes supporting remote file gateways.
org.springframework.integration.file.splitter	Provides implementations of AbstractMessageSplitter.
org.springframework.integration.file.tail	Classes used for tailing file system files.
org.springframework.integration.filter	Provides classes supporting the filter pattern.
org.springframework.integration.ftp.gateway	Provides classes supporting FTP gateways.
org.springframework.integration.gateway	Provides classes supporting messaging gateways.
org.springframework.integration.graphql.outbound	Provides classes for GraphQL outbound channel adapters.
org.springframework.integration.handler	Provides classes implementing various types of message handler.
org.springframework.integration.hazelcast.inbound	Provides classes supporting inbound endpoints.
org.springframework.integration.http.outbound	Provides classes supporting outbound endpoints.
org.springframework.integration.ip	Base package for IP (TCP/UDP) Support.
org.springframework.integration.ip.tcp	Base package for TCP Support.
org.springframework.integration.ip.udp	Base package for UDP support.
org.springframework.integration.jdbc	Root package of the Spring Integration JDBC module, which contains various JDBC and Stored Procedure/Function supporting components.
org.springframework.integration.jms	Base package for JMS Support.
org.springframework.integration.jmx	Base package for JMX support.
org.springframework.integration.jpa.outbound	Provides Spring Integration components for doing outbound operations.
org.springframework.integration.kafka.inbound	Provides Spring Integration inbound components for Apache Kafka.
org.springframework.integration.kafka.outbound	Provides Spring Integration outbound components for Apache Kafka.
org.springframework.integration.mail	Base package for Mail support.
org.springframework.integration.mongodb.inbound	Provides classes related to the Mongo inbound channel adapters
org.springframework.integration.mongodb.outbound	Provides classes related to the Mongo outbound channel adapters
org.springframework.integration.mqtt.inbound	Provides inbound Spring Integration MqttAdapter components.
org.springframework.integration.redis.inbound	Provides classes supporting inbound endpoints.
org.springframework.integration.redis.outbound	Provides classes supporting outbound endpoints.
org.springframework.integration.rsocket.outbound	Provides classes representing outbound RSocket components.
org.springframework.integration.scattergather	Provides classes supporting the Scatter-Gather pattern.
org.springframework.integration.sftp.gateway	Provides classes supporting SFTP gateways.
org.springframework.integration.smb.outbound	Outbound Channel Adapter implementations for SMB protocol.
org.springframework.integration.splitter	Provides classes supporting the splitter pattern.
org.springframework.integration.stomp.inbound	Provides classes which represent inbound STOMP components.
org.springframework.integration.syslog.inbound	Provides classes for inbound endpoints.
org.springframework.integration.test.mock	Utilities for mocking integration components.
org.springframework.integration.transformer	Contains core-implementation of various Transformers which includes Enrichers and Filters.
org.springframework.integration.webflux.outbound	Provides classes supporting outbound endpoints.
org.springframework.integration.websocket.inbound	Provides classes which represent inbound WebSocket components.
org.springframework.integration.ws	Provides several inbound and outbound Web Service components.
org.springframework.integration.xml.splitter	Provides implementations of AbstractMessageSplitter.
org.springframework.integration.xmpp.core	Provides classes shared across all XMPP components.
org.springframework.integration.xmpp.inbound	Provides XMPP inbound Endpoint implementations that extend AbstractXmppConnectionAwareEndpoint.
org.springframework.integration.zeromq.inbound	Provides classes for inbound channel adapters over ZeroMQ.
org.springframework.integration.zip.splitter	Classes to support Splitter pattern for Zip.

Uses of MessageProducer in org.springframework.integration.aggregator

Classes in org.springframework.integration.aggregator that implement MessageProducer

Modifier and Type	Class	Description
class	AbstractCorrelatingMessageHandler	Abstract Message handler that holds a buffer of correlated messages in a MessageStore.
class	AggregatingMessageHandler	Aggregator specific implementation of AbstractCorrelatingMessageHandler.
class	BarrierMessageHandler	A message handler that suspends the thread until a message with corresponding correlation is passed into the trigger method or the timeout occurs.
class	FluxAggregatorMessageHandler	The AbstractMessageProducingHandler implementation for aggregation logic based on Reactor's Flux.groupBy(java.util.function.Function<? super T, ? extends K>) and Flux.window(int) operators.
class	ResequencingMessageHandler	Resequencer specific implementation of AbstractCorrelatingMessageHandler.

Uses of MessageProducer in org.springframework.integration.amqp.inbound

Classes in org.springframework.integration.amqp.inbound that implement MessageProducer

Modifier and Type	Class	Description
class	AmqpInboundChannelAdapter	Adapter that receives Messages from an AMQP Queue, converts them into Spring Integration Messages, and sends the results to a Message Channel.

Uses of MessageProducer in org.springframework.integration.amqp.outbound

Classes in org.springframework.integration.amqp.outbound that implement MessageProducer

Modifier and Type	Class	Description
class	AbstractAmqpOutboundEndpoint	A base AbstractReplyProducingMessageHandler extension for AMQP message handlers.
class	AmqpOutboundEndpoint	Adapter that converts and sends Messages to an AMQP Exchange.
class	AsyncAmqpOutboundGateway	An outbound gateway where the sending thread is released immediately and the reply is sent on the async template's listener container thread.

Uses of MessageProducer in org.springframework.integration.camel.outbound

Classes in org.springframework.integration.camel.outbound that implement MessageProducer

Modifier and Type	Class	Description
class	CamelMessageHandler	A MessageHandler for calling Apache Camel route and produce (optionally) a reply.

Uses of MessageProducer in org.springframework.integration.cassandra.outbound

Classes in org.springframework.integration.cassandra.outbound that implement MessageProducer

Modifier and Type	Class	Description
class	CassandraMessageHandler	An AbstractReplyProducingMessageHandler implementation for Cassandra outbound operations.

Uses of MessageProducer in org.springframework.integration.debezium.inbound

Classes in org.springframework.integration.debezium.inbound that implement MessageProducer

Modifier and Type	Class	Description
class	DebeziumMessageProducer	Debezium Change Event Channel Adapter.

Uses of MessageProducer in org.springframework.integration.dsl

Methods in org.springframework.integration.dsl with parameters of type MessageProducer

Modifier and Type	Method	Description
protected void	BaseIntegrationFlowDefinition.checkReuse(MessageProducer replyHandler)

Uses of MessageProducer in org.springframework.integration.endpoint

Classes in org.springframework.integration.endpoint that implement MessageProducer

Modifier and Type	Class	Description
class	ExpressionMessageProducerSupport	A MessageProducerSupport sub-class that provides ExpressionMessageProducerSupport.payloadExpression evaluation with result as a payload for Message to send.
class	MessageProducerSupport	A support class for producer endpoints that provides a setter for the output channel and a convenience method for sending Messages.
class	ReactiveMessageSourceProducer	The MessageProducerSupport to adapt a provided MessageSource into a Flux and let it be subscribed in the MessageProducerSupport.subscribeToPublisher(org.reactivestreams.Publisher<? extends org.springframework.messaging.Message<?>>).

Uses of MessageProducer in org.springframework.integration.event.inbound

Classes in org.springframework.integration.event.inbound that implement MessageProducer

Modifier and Type	Class	Description
class	ApplicationEventListeningMessageProducer	An inbound Channel Adapter that implements GenericApplicationListener and passes Spring ApplicationEvents within messages.

Uses of MessageProducer in org.springframework.integration.file

Classes in org.springframework.integration.file that implement MessageProducer

Modifier and Type	Class	Description
class	FileWritingMessageHandler	A MessageHandler implementation that writes the Message payload to a file.

Uses of MessageProducer in org.springframework.integration.file.remote.gateway

Classes in org.springframework.integration.file.remote.gateway that implement MessageProducer

Modifier and Type	Class	Description
class	AbstractRemoteFileOutboundGateway<F>	Base class for Outbound Gateways that perform remote file operations.

Uses of MessageProducer in org.springframework.integration.file.splitter

Classes in org.springframework.integration.file.splitter that implement MessageProducer

Modifier and Type	Class	Description
class	FileSplitter	The AbstractMessageSplitter implementation to split the File Message payload to lines.

Uses of MessageProducer in org.springframework.integration.file.tail

Classes in org.springframework.integration.file.tail that implement MessageProducer

Modifier and Type	Class	Description
class	ApacheCommonsFileTailingMessageProducer	File tailer that delegates to the Apache Commons Tailer.
class	FileTailingMessageProducerSupport	Base class for file tailing inbound adapters.
class	OSDelegatingFileTailingMessageProducer	A file tailing message producer that delegates to the OS tail program.

Uses of MessageProducer in org.springframework.integration.filter

Classes in org.springframework.integration.filter that implement MessageProducer

Modifier and Type	Class	Description
class	MessageFilter	Message Handler that delegates to a MessageSelector.

Uses of MessageProducer in org.springframework.integration.ftp.gateway

Classes in org.springframework.integration.ftp.gateway that implement MessageProducer

Modifier and Type	Class	Description
class	FtpOutboundGateway	Outbound Gateway for performing remote file operations via FTP/FTPS.

Uses of MessageProducer in org.springframework.integration.gateway

Classes in org.springframework.integration.gateway that implement MessageProducer

Modifier and Type	Class	Description
class	GatewayMessageHandler	The AbstractReplyProducingMessageHandler implementation for mid-flow Gateway.

Uses of MessageProducer in org.springframework.integration.graphql.outbound

Classes in org.springframework.integration.graphql.outbound that implement MessageProducer

Modifier and Type	Class	Description
class	GraphQlMessageHandler	An AbstractReplyProducingMessageHandler capable of fielding GraphQL Query, Mutation and Subscription requests.

Uses of MessageProducer in org.springframework.integration.handler

Classes in org.springframework.integration.handler that implement MessageProducer

Modifier and Type	Class	Description
class	AbstractMessageProducingHandler	The base AbstractMessageHandler implementation for the MessageProducer.
class	AbstractReplyProducingMessageHandler	Base class for MessageHandlers that are capable of producing replies.
class	AbstractReplyProducingPostProcessingMessageHandler
class	BridgeHandler	A simple MessageHandler implementation that passes the request Message directly to the output channel without modifying it.
class	DelayHandler	A MessageHandler that is capable of delaying the continuation of a Message flow based on the result of evaluation delayExpression on an inbound Message or a default delay value configured on this handler.
class	MessageHandlerChain	A composite MessageHandler implementation that invokes a chain of MessageHandler instances in order.
class	ReplyProducingMessageHandlerWrapper	The AbstractReplyProducingMessageHandler wrapper around raw MessageHandler for request-reply scenarios, e.g.
class	ServiceActivatingHandler

Uses of MessageProducer in org.springframework.integration.hazelcast.inbound

Classes in org.springframework.integration.hazelcast.inbound that implement MessageProducer

Modifier and Type	Class	Description
class	AbstractHazelcastMessageProducer	Hazelcast Base Event-Driven Message Producer.
class	HazelcastClusterMonitorMessageProducer	Hazelcast Cluster Monitor Event Driven Message Producer is a message producer which enables HazelcastClusterMonitorMessageProducer.HazelcastClusterMonitorListener listener in order to listen cluster related events and sends events to related channel.
class	HazelcastContinuousQueryMessageProducer	Hazelcast Continuous Query Message Producer is a message producer which enables AbstractHazelcastMessageProducer.HazelcastEntryListener with a SqlPredicate in order to listen related distributed map events in the light of defined predicate and sends events to related channel.
class	HazelcastEventDrivenMessageProducer	Hazelcast Event Driven Message Producer is a message producer which enables AbstractHazelcastMessageProducer.HazelcastEntryListener, HazelcastEventDrivenMessageProducer.HazelcastItemListener and HazelcastEventDrivenMessageProducer.HazelcastMessageListener listeners in order to listen related cache events and sends events to related channel.

Uses of MessageProducer in org.springframework.integration.http.outbound

Classes in org.springframework.integration.http.outbound that implement MessageProducer

Modifier and Type	Class	Description
class	AbstractHttpRequestExecutingMessageHandler	Base class for http outbound adapter/gateway.
class	HttpRequestExecutingMessageHandler	A MessageHandler implementation that executes HTTP requests by delegating to a RestTemplate instance.

Uses of MessageProducer in org.springframework.integration.ip

Classes in org.springframework.integration.ip that implement MessageProducer

Modifier and Type	Class	Description
class	AbstractInternetProtocolReceivingChannelAdapter	Base class for inbound TCP/UDP Channel Adapters.

Uses of MessageProducer in org.springframework.integration.ip.tcp

Classes in org.springframework.integration.ip.tcp that implement MessageProducer

Modifier and Type	Class	Description
class	TcpOutboundGateway	TCP outbound gateway that uses a client connection factory.
class	TcpReceivingChannelAdapter	Tcp inbound channel adapter using a TcpConnection to receive data - if the connection factory is a server factory, this Listener owns the connections.

Uses of MessageProducer in org.springframework.integration.ip.udp

Classes in org.springframework.integration.ip.udp that implement MessageProducer

Modifier and Type	Class	Description
class	MulticastReceivingChannelAdapter	Channel adapter that joins a multicast group and receives incoming packets and sends them to an output channel.
class	UnicastReceivingChannelAdapter	A channel adapter to receive incoming UDP packets.

Uses of MessageProducer in org.springframework.integration.jdbc

Classes in org.springframework.integration.jdbc that implement MessageProducer

Modifier and Type	Class	Description
class	JdbcOutboundGateway
class	StoredProcOutboundGateway	An AbstractReplyProducingMessageHandler implementation for performing RDBMS stored procedures which return results.

Uses of MessageProducer in org.springframework.integration.jms

Classes in org.springframework.integration.jms that implement MessageProducer

Modifier and Type	Class	Description
class	JmsMessageDrivenEndpoint	A message-driven endpoint that receive JMS messages, converts them into Spring Integration Messages, and then sends the result to a channel.
class	JmsOutboundGateway	An outbound Messaging Gateway for request/reply JMS.

Uses of MessageProducer in org.springframework.integration.jmx

Classes in org.springframework.integration.jmx that implement MessageProducer

Modifier and Type	Class	Description
class	NotificationListeningMessageProducer	A JMX NotificationListener implementation that will send Messages containing the JMX Notification instances as their payloads.
class	OperationInvokingMessageHandler	A MessageHandler implementation for invoking JMX operations based on the Message sent to its AbstractMessageHandler.handleMessage(Message) method.

Uses of MessageProducer in org.springframework.integration.jpa.outbound

Classes in org.springframework.integration.jpa.outbound that implement MessageProducer

Modifier and Type	Class	Description
class	JpaOutboundGateway	The Jpa Outbound Gateway will allow you to make outbound operations to either: submit (insert, delete) data to a database using JPA retrieve (select) data from a database Depending on the selected OutboundGatewayType, the outbound gateway will use either the JpaExecutor's poll method or its executeOutboundJpaOperation method.

Uses of MessageProducer in org.springframework.integration.kafka.inbound

Classes in org.springframework.integration.kafka.inbound that implement MessageProducer

Modifier and Type	Class	Description
class	KafkaMessageDrivenChannelAdapter<K,V>	Message-driven channel adapter.

Uses of MessageProducer in org.springframework.integration.kafka.outbound

Classes in org.springframework.integration.kafka.outbound that implement MessageProducer

Modifier and Type	Class	Description
class	KafkaProducerMessageHandler<K,V>	A Message Handler for Apache Kafka; when supplied with a ReplyingKafkaTemplate it is used as the handler in an outbound gateway.

Uses of MessageProducer in org.springframework.integration.mail

Classes in org.springframework.integration.mail that implement MessageProducer

Modifier and Type	Class	Description
class	ImapIdleChannelAdapter	An event-driven Channel Adapter that receives mail messages from a mail server that supports the IMAP "idle" command (see RFC 2177).

Uses of MessageProducer in org.springframework.integration.mongodb.inbound

Classes in org.springframework.integration.mongodb.inbound that implement MessageProducer

Modifier and Type	Class	Description
class	MongoDbChangeStreamMessageProducer	A MessageProducerSupport for MongoDB Change Stream implementation.

Uses of MessageProducer in org.springframework.integration.mongodb.outbound

Classes in org.springframework.integration.mongodb.outbound that implement MessageProducer

Modifier and Type	Class	Description
class	MongoDbOutboundGateway	Makes outbound operations to query a MongoDb database using a MongoOperations.

Uses of MessageProducer in org.springframework.integration.mqtt.inbound

Classes in org.springframework.integration.mqtt.inbound that implement MessageProducer

Modifier and Type	Class	Description
class	AbstractMqttMessageDrivenChannelAdapter<T,C>	Abstract class for MQTT Message-Driven Channel Adapters.
class	MqttPahoMessageDrivenChannelAdapter	Eclipse Paho Implementation.
class	Mqttv5PahoMessageDrivenChannelAdapter	The AbstractMqttMessageDrivenChannelAdapter implementation for MQTT v5.

Uses of MessageProducer in org.springframework.integration.redis.inbound

Classes in org.springframework.integration.redis.inbound that implement MessageProducer

Modifier and Type	Class	Description
class	ReactiveRedisStreamMessageProducer	A MessageProducerSupport for reading messages from a Redis Stream and publishing them into the provided output channel.
class	RedisInboundChannelAdapter
class	RedisQueueMessageDrivenEndpoint

Uses of MessageProducer in org.springframework.integration.redis.outbound

Classes in org.springframework.integration.redis.outbound that implement MessageProducer

Modifier and Type	Class	Description
class	RedisOutboundGateway	The Gateway component implementation to perform Redis commands with provided arguments and to return command result.
class	RedisQueueOutboundGateway

Uses of MessageProducer in org.springframework.integration.rsocket.outbound

Classes in org.springframework.integration.rsocket.outbound that implement MessageProducer

Modifier and Type	Class	Description
class	RSocketOutboundGateway	An Outbound Messaging Gateway for RSocket requests.

Uses of MessageProducer in org.springframework.integration.scattergather

Classes in org.springframework.integration.scattergather that implement MessageProducer

Modifier and Type	Class	Description
class	ScatterGatherHandler	The MessageHandler implementation for the Scatter-Gather EIP pattern.

Uses of MessageProducer in org.springframework.integration.sftp.gateway

Classes in org.springframework.integration.sftp.gateway that implement MessageProducer

Modifier and Type	Class	Description
class	SftpOutboundGateway	Outbound Gateway for performing remote file operations via SFTP.

Uses of MessageProducer in org.springframework.integration.smb.outbound

Classes in org.springframework.integration.smb.outbound that implement MessageProducer

Modifier and Type	Class	Description
class	SmbOutboundGateway	Outbound Gateway for performing remote file operations via SMB.

Uses of MessageProducer in org.springframework.integration.splitter

Classes in org.springframework.integration.splitter that implement MessageProducer

Modifier and Type	Class	Description
class	AbstractMessageSplitter	Base class for Message-splitting handlers.
class	DefaultMessageSplitter	The default Message Splitter implementation.
class	ExpressionEvaluatingSplitter	A Message Splitter implementation that evaluates the specified SpEL expression.
class	MethodInvokingSplitter	A Message Splitter implementation that invokes the specified method on the given object.

Uses of MessageProducer in org.springframework.integration.stomp.inbound

Classes in org.springframework.integration.stomp.inbound that implement MessageProducer

Modifier and Type	Class	Description
class	StompInboundChannelAdapter	The MessageProducerSupport for STOMP protocol to handle STOMP frames from provided destination and send messages to the outputChannel.

Uses of MessageProducer in org.springframework.integration.syslog.inbound

Classes in org.springframework.integration.syslog.inbound that implement MessageProducer

Modifier and Type	Class	Description
class	SyslogReceivingChannelAdapterSupport	Base support class for inbound channel adapters.
class	TcpSyslogReceivingChannelAdapter	TCP implementation of a syslog inbound channel adapter.
class	UdpSyslogReceivingChannelAdapter	UDP implementation of a syslog inbound channel adapter.

Uses of MessageProducer in org.springframework.integration.test.mock

Classes in org.springframework.integration.test.mock that implement MessageProducer

Modifier and Type	Class	Description
class	MockMessageHandler	The AbstractMessageProducingHandler extension for the mocking purpose in tests.

Uses of MessageProducer in org.springframework.integration.transformer

Classes in org.springframework.integration.transformer that implement MessageProducer

Modifier and Type	Class	Description
class	ContentEnricher	Content Enricher is a Message Transformer that can augment a message's payload with either static values or by optionally invoking a downstream message flow via its request channel and then applying values from the reply Message to the original payload.
class	MessageTransformingHandler	A reply-producing MessageHandler that delegates to a Transformer instance to modify the received Message and sends the result to its output channel.

Uses of MessageProducer in org.springframework.integration.webflux.outbound

Classes in org.springframework.integration.webflux.outbound that implement MessageProducer

Modifier and Type	Class	Description
class	WebFluxRequestExecutingMessageHandler	A MessageHandler implementation that executes HTTP requests by delegating to a Reactive WebClient instance.

Uses of MessageProducer in org.springframework.integration.websocket.inbound

Classes in org.springframework.integration.websocket.inbound that implement MessageProducer

Modifier and Type	Class	Description
class	WebSocketInboundChannelAdapter	The MessageProducerSupport for inbound WebSocket messages.

Uses of MessageProducer in org.springframework.integration.ws

Classes in org.springframework.integration.ws that implement MessageProducer

Modifier and Type	Class	Description
class	AbstractWebServiceOutboundGateway	Base class for outbound Web Service-invoking Messaging Gateways.
class	MarshallingWebServiceOutboundGateway	An outbound Messaging Gateway for invoking Web Services that also supports marshalling and unmarshalling of the request and response messages.
class	SimpleWebServiceOutboundGateway	An outbound Messaging Gateway for invoking a Web Service.

Uses of MessageProducer in org.springframework.integration.xml.splitter

Classes in org.springframework.integration.xml.splitter that implement MessageProducer

Modifier and Type	Class	Description
class	XPathMessageSplitter	Message Splitter that uses an XPathExpression to split a Document, File or String payload into a NodeList.

Uses of MessageProducer in org.springframework.integration.xmpp.core

Classes in org.springframework.integration.xmpp.core that implement MessageProducer

Modifier and Type	Class	Description
class	AbstractXmppConnectionAwareEndpoint

Uses of MessageProducer in org.springframework.integration.xmpp.inbound

Classes in org.springframework.integration.xmpp.inbound that implement MessageProducer

Modifier and Type	Class	Description
class	ChatMessageListeningEndpoint	This component logs in as a user and forwards any messages to that user on to downstream components.
class	PresenceListeningEndpoint	An inbound endpoint that is able to login and then emit particular Presence event occurs within the logged-in user's Roster.

Uses of MessageProducer in org.springframework.integration.zeromq.inbound

Classes in org.springframework.integration.zeromq.inbound that implement MessageProducer

Modifier and Type	Class	Description
class	ZeroMqMessageProducer	A MessageProducerSupport implementation for consuming messages from ZeroMq socket.

Uses of MessageProducer in org.springframework.integration.zip.splitter

Classes in org.springframework.integration.zip.splitter that implement MessageProducer

Modifier and Type	Class	Description
class	UnZipResultSplitter