A C G I M O U V

A

ack() - Method in interface org.eclipse.microprofile.reactive.messaging.Message

Acknowledge this message.

Acknowledgment - Annotation Type in org.eclipse.microprofile.reactive.messaging

Configure the acknowledgement policy for the given @Incoming.

Acknowledgment.Strategy - Enum in org.eclipse.microprofile.reactive.messaging

C

CHANNEL_NAME_ATTRIBUTE - Static variable in interface org.eclipse.microprofile.reactive.messaging.spi.ConnectorFactory

The channel-name attribute name.

Connector - Annotation Type in org.eclipse.microprofile.reactive.messaging.spi

Qualifier used on connector implementations to indicate the associated underlying transport.

CONNECTOR_ATTRIBUTE - Static variable in interface org.eclipse.microprofile.reactive.messaging.spi.ConnectorFactory

The connector attribute name.

CONNECTOR_PREFIX - Static variable in interface org.eclipse.microprofile.reactive.messaging.spi.ConnectorFactory

Prefix used in the MicroProfile Config to configure properties shared by all the channels associated with a specific connector.

ConnectorFactory - Interface in org.eclipse.microprofile.reactive.messaging.spi

Parent class for IncomingConnectorFactory and OutgoingConnectorFactory.

ConnectorLiteral - Class in org.eclipse.microprofile.reactive.messaging.spi

Supports inline instantiation of the Connector qualifier.

G

getPayload() - Method in interface org.eclipse.microprofile.reactive.messaging.Message

getPublisherBuilder(Config) - Method in interface org.eclipse.microprofile.reactive.messaging.spi.IncomingConnectorFactory

Creates a channel for the given configuration.

getSubscriberBuilder(Config) - Method in interface org.eclipse.microprofile.reactive.messaging.spi.OutgoingConnectorFactory

Creates a channel for the given configuration.

I

Incoming - Annotation Type in org.eclipse.microprofile.reactive.messaging

Used to signify a subscriber to incoming messages.

INCOMING_PREFIX - Static variable in interface org.eclipse.microprofile.reactive.messaging.spi.ConnectorFactory

Prefix used in the MicroProfile Config to configure an incoming channel.

IncomingConnectorFactory - Interface in org.eclipse.microprofile.reactive.messaging.spi

SPI used to implement a connector managing a source of messages for a specific transport.

M

Message<T> - Interface in org.eclipse.microprofile.reactive.messaging

A message envelope.

O

of(T) - Static method in interface org.eclipse.microprofile.reactive.messaging.Message

Create a message with the given payload.

of(T, Supplier<CompletionStage<Void>>) - Static method in interface org.eclipse.microprofile.reactive.messaging.Message

Create a message with the given payload and ack function.

of(String) - Static method in class org.eclipse.microprofile.reactive.messaging.spi.ConnectorLiteral

Creates a new instance of ConnectorLiteral.

org.eclipse.microprofile.reactive.messaging - package org.eclipse.microprofile.reactive.messaging

The MicroProfile Reactive Messaging API.

org.eclipse.microprofile.reactive.messaging.spi - package org.eclipse.microprofile.reactive.messaging.spi

The MicroProfile Reactive Messaging API Connector SPI

Outgoing - Annotation Type in org.eclipse.microprofile.reactive.messaging

Used to signify a publisher of outgoing messages.

OUTGOING_PREFIX - Static variable in interface org.eclipse.microprofile.reactive.messaging.spi.ConnectorFactory

Prefix used in the MicroProfile Config to configure an outgoing channel.

OutgoingConnectorFactory - Interface in org.eclipse.microprofile.reactive.messaging.spi

SPI used to implement a connector managing a sink of messages for a specific transport.

U

unwrap(Class<C>) - Method in interface org.eclipse.microprofile.reactive.messaging.Message

Returns an object of the specified type to allow access to the connector-specific Message implementation, and other classes.

V

value() - Method in class org.eclipse.microprofile.reactive.messaging.spi.ConnectorLiteral

valueOf(String) - Static method in enum org.eclipse.microprofile.reactive.messaging.Acknowledgment.Strategy

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.eclipse.microprofile.reactive.messaging.Acknowledgment.Strategy

Returns an array containing the constants of this enum type, in the order they are declared.

A C G I M O U V