@Version(value="2.0")

# Package org.eclipse.microprofile.reactive.messaging.spi

The MicroProfile Reactive Messaging API Connector SPI

See: Description

Interface Summary
ConnectorFactory: Parent class for `IncomingConnectorFactory` and `OutgoingConnectorFactory`.
IncomingConnectorFactory: SPI used to implement a connector managing a source of messages for a specific transport.
OutgoingConnectorFactory: SPI used to implement a connector managing a sink of messages for a specific transport.

Class Summary
ConnectorLiteral: Supports inline instantiation of the `Connector` qualifier.

Enum Summary
ConnectorAttribute.Direction: Attribute direction.

Annotation Types Summary
Connector: Qualifier used on connector implementations to indicate the associated underlying transport.
ConnectorAttribute: Connector implementor can use this annotation to document attributes supported by their connector.
ConnectorAttributes: This class is used to allow multiple `ConnectorAttribute` declarations.

## Package org.eclipse.microprofile.reactive.messaging.spi Description

The MicroProfile Reactive Messaging API Connector SPI

This package provides the SPI to implement `connectors`. A `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 `IncomingConnectorFactory` interface.
- 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 `OutgoingConnectorFactory` interface.

Connectors are implemented as CDI beans and identified using the `Connector` qualifier. Connectors receive the channel configuration matching their `Connector` name.