Interface MessagingConnector

All Superinterfaces:

NamedService

public interface MessagingConnector
extends NamedService

A configured messaging connector capable of creating channel connections.

An implementation must support at least one direction by overriding incoming(MessagingIncomingConfig), outgoing(MessagingOutgoingConfig), or both. Each successful invocation must return a fresh, unstarted channel connection.

Method Summary

Modifier and Type	Method	Description
default Optional<IncomingChannel>	incoming(MessagingIncomingConfig channelConfig)	Create an incoming channel connection.
default String	name()	Name of this implementation, as provided in ConfiguredProvider.create(Config, String).
default Optional<OutgoingChannel>	outgoing(MessagingOutgoingConfig channelConfig)	Create an outgoing channel connection.
MessagingConnectorProviderConfig	prototype()	Configuration used to create this connector.

Methods inherited from interface NamedService

type

Modifier and Type	Method	Description
String	type()	Type of this implementation, to distinguish instances of same type, with different NamedService.name().

Method Details

prototype

MessagingConnectorProviderConfig prototype()

Configuration used to create this connector.

Returns:

connector configuration

name

default String name()

Description copied from interface: NamedService

Name of this implementation, as provided in ConfiguredProvider.create(Config, String).

Specified by:

name in interface NamedService

Returns:

name of this service

incoming

default Optional<IncomingChannel> incoming(MessagingIncomingConfig channelConfig)

Create an incoming channel connection.

Parameters:

channelConfig - channel-specific configuration

Returns:

incoming channel connection, or empty if this connector does not support incoming channels

outgoing

default Optional<OutgoingChannel> outgoing(MessagingOutgoingConfig channelConfig)

Create an outgoing channel connection.

Parameters:

channelConfig - channel-specific configuration

Returns:

outgoing channel connection, or empty if this connector does not support outgoing channels