This package provides the SPI to implement
connector can be seen as a Reactive Messaging
plug-in to support a specific messaging technology. For example, you can have a Kafka connector to deal with Kafka,
an AMQP connector to interact with AMQP brokers and routers and so on. Connector implementation should be
agnostic to the Reactive Messaging implementation.
A connector can be seen as:
- a source of messages - it retrieves messages and injects them into the Reactive Messaging application. To
manage this direction, the connector implementation must implement the
- a sink of messages - it forwards messages emitted by the Reactive Messaging application to the managed
technology. To achieve this, the connector implementation must implement the
Connectorqualifier. Connectors receive the channel configuration matching their
Interface Summary Interface Description ConnectorFactory IncomingConnectorFactorySPI used to implement a connector managing a source of messages for a specific transport. OutgoingConnectorFactorySPI used to implement a connector managing a sink of messages for a specific transport.
Class Summary Class Description ConnectorLiteralSupports inline instantiation of the
Annotation Types Summary Annotation Type Description ConnectorQualifier used on connector implementations to indicate the associated underlying transport.