Package io.smallrye.reactive.messaging.amqp

Class AmqpConnector

java.lang.Object

io.smallrye.reactive.messaging.amqp.AmqpConnector

All Implemented Interfaces:

HealthReporter, ConnectorFactory, IncomingConnectorFactory, OutgoingConnectorFactory

@ApplicationScoped
public class AmqpConnector
extends Object
implements IncomingConnectorFactory, OutgoingConnectorFactory, HealthReporter

Field Summary

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

CHANNEL_NAME_ATTRIBUTE, CONNECTOR_ATTRIBUTE, CONNECTOR_PREFIX, INCOMING_PREFIX, OUTGOING_PREFIX

Method Summary

Modifier and Type	Method	Description
void	addClient(io.vertx.mutiny.amqp.AmqpClient client)
List<io.vertx.mutiny.amqp.AmqpClient>	getClients()
HealthReport	getLiveness()
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	getPublisherBuilder(org.eclipse.microprofile.config.Config config)	Creates a channel for the given configuration.
HealthReport	getReadiness()
org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void>	getSubscriberBuilder(org.eclipse.microprofile.config.Config config)	Creates a channel for the given configuration.
io.vertx.mutiny.core.Vertx	getVertx()
void	reportFailure(String channel, Throwable reason)
void	terminate(Object event)

Methods inherited from class java.lang.Object

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

Method Detail

getPublisherBuilder

public org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> getPublisherBuilder(org.eclipse.microprofile.config.Config config)

Description copied from interface: IncomingConnectorFactory

Creates a channel for the given configuration. The channel's configuration is associated with a specific connector, using the Connector qualifier's parameter indicating a key to which IncomingConnectorFactory to use.

Note that the connection to the transport or broker is generally postponed until the subscription occurs.

Specified by:

getPublisherBuilder in interface IncomingConnectorFactory

Parameters:

config - the configuration, must not be null, must contain the ConnectorFactory.CHANNEL_NAME_ATTRIBUTE attribute.

Returns:

the created PublisherBuilder, will not be null.

getSubscriberBuilder

public org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void> getSubscriberBuilder(org.eclipse.microprofile.config.Config config)

Description copied from interface: OutgoingConnectorFactory

Creates a channel for the given configuration. The channel's configuration is associated with a specific connector, using the Connector qualifier's parameter indicating a key to which Outgoing to use.

Note that the connection to the transport or broker is generally postponed until the subscription.

Specified by:

getSubscriberBuilder in interface OutgoingConnectorFactory

Parameters:

config - the configuration, never null, must contain the ConnectorFactory.CHANNEL_NAME_ATTRIBUTE attribute.

Returns:

the created SubscriberBuilder, must not be null.

terminate

public void terminate(@Observes(notifyObserver=IF_EXISTS) @Priority(50) @BeforeDestroyed(javax.enterprise.context.ApplicationScoped.class)
                      Object event)

getVertx

public io.vertx.mutiny.core.Vertx getVertx()

addClient

public void addClient(io.vertx.mutiny.amqp.AmqpClient client)

getClients

public List<io.vertx.mutiny.amqp.AmqpClient> getClients()

getReadiness

public HealthReport getReadiness()

Specified by:

getReadiness in interface HealthReporter

getLiveness

public HealthReport getLiveness()

Specified by:

getLiveness in interface HealthReporter

reportFailure

public void reportFailure(String channel,
                          Throwable reason)