Module helidon.messaging.mock

Package io.helidon.messaging.connectors.mock

Class MockConnector

java.lang.Object

io.helidon.messaging.connectors.mock.MockConnector

All Implemented Interfaces:

ConnectorFactory, IncomingConnectorFactory, OutgoingConnectorFactory

@ApplicationScoped
public class MockConnector
extends Object
implements IncomingConnectorFactory, OutgoingConnectorFactory

Helidon messaging mock connector for testing purposes. Mock connector for testing Helidon messaging without the need of connection to actual messaging broker.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CONNECTOR_NAME	Connector name.

Fields inherited from interface org.eclipse.microprofile.reactive.messaging.spi.ConnectorFactory

CHANNEL_NAME_ATTRIBUTE, CONNECTOR_ATTRIBUTE, CONNECTOR_PREFIX, INCOMING_PREFIX, OUTGOING_PREFIX

Constructor Summary

Constructors

Constructor	Description
MockConnector()

Method Summary

Modifier and Type	Method	Description
PublisherBuilder<? extends Message<?>>	getPublisherBuilder(Config config)
SubscriberBuilder<? extends Message<?>,Void>	getSubscriberBuilder(Config config)
<P> MockIncoming<P>	incoming(String channelName, Class<P> type)	Retrieve mocker for incoming channel.
<P> MockOutgoing<P>	outgoing(String channelName, Class<P> type)	Retrieve mocker for outgoing channel.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

CONNECTOR_NAME

public static final String CONNECTOR_NAME

Connector name.

See Also:

• Constant Field Values

Constructor Details

MockConnector

public MockConnector()

Method Details

getPublisherBuilder

public PublisherBuilder<? extends Message<?>> getPublisherBuilder(Config config)

Specified by:

getPublisherBuilder in interface IncomingConnectorFactory

getSubscriberBuilder

public SubscriberBuilder<? extends Message<?>,Void> getSubscriberBuilder(Config config)

Specified by:

getSubscriberBuilder in interface OutgoingConnectorFactory

incoming

public <P> MockIncoming<P> incoming(String channelName,
 Class<P> type)

Retrieve mocker for incoming channel. Incoming channel needs to be configured to use MockConnector with:

 @AddConfig(key = "mp.messaging.incoming.test-channel-incoming", value = MockConnector.CONNECTOR_NAME)
 

Type Parameters:

P - type of the payload

Parameters:

channelName - Channel name, for example test-channel-incoming

type - Type of the payload

Returns:

mocker for desired chanel

outgoing

public <P> MockOutgoing<P> outgoing(String channelName,
 Class<P> type)

Retrieve mocker for outgoing channel. Outgoing channel needs to be configured to use MockConnector with:

 @AddConfig(key = "mp.messaging.outgoing.test-channel-outgoing", value = MockConnector.CONNECTOR_NAME)
 

Type Parameters:

P - type of the payload

Parameters:

channelName - Channel name, for example test-channel-outgoing

type - Type of the payload

Returns:

mocker for desired chanel