A C E G H I M N O S U V W

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 - Annotation Type in org.eclipse.microprofile.reactive.messaging

This qualifier indicates which channel should be injected / populated.

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

The channel-name attribute name.

complete() - Method in interface org.eclipse.microprofile.reactive.messaging.Emitter

Sends the completion event to the channel indicating that no other events will be sent afterward.

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.

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

Connector implementor can use this annotation to document attributes supported by their connector.

ConnectorAttribute.Direction - Enum in org.eclipse.microprofile.reactive.messaging.spi

Attribute direction.

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

This class is used to allow multiple ConnectorAttribute declarations.

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.

E

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

Interface used to feed a channel from an imperative piece of code.

error(Exception) - Method in interface org.eclipse.microprofile.reactive.messaging.Emitter

Sends a failure event to the channel.

G

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

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

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.

H

hasRequests() - Method in interface org.eclipse.microprofile.reactive.messaging.Emitter

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.

isCancelled() - Method in interface org.eclipse.microprofile.reactive.messaging.Emitter

M

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

A message envelope.

N

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

Acknowledge negatively this message.

NO_VALUE - Static variable in annotation type org.eclipse.microprofile.reactive.messaging.spi.ConnectorAttribute

The constant used to indicate that the attribute has no default value or no alias.

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(T, Supplier<CompletionStage<Void>>, Function<Throwable, CompletionStage<Void>>) - Static method in interface org.eclipse.microprofile.reactive.messaging.Message

Create a message with the given payload, ack and nack functions.

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

Creates a new instance of ConnectorLiteral.

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

Configures the back pressure policy on an injected Emitter:

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

The back pressure strategy.

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.

S

send(T) - Method in interface org.eclipse.microprofile.reactive.messaging.Emitter

Sends a payload to the channel.

send(M) - Method in interface org.eclipse.microprofile.reactive.messaging.Emitter

Sends a message to the channel.

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.

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

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

valueOf(String) - Static method in enum org.eclipse.microprofile.reactive.messaging.spi.ConnectorAttribute.Direction

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.

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

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

values() - Static method in enum org.eclipse.microprofile.reactive.messaging.spi.ConnectorAttribute.Direction

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

W

withAck(Supplier<CompletionStage<Void>>) - Method in interface org.eclipse.microprofile.reactive.messaging.Message

Creates a new instance of Message with the given acknowledgement supplier.

withNack(Function<Throwable, CompletionStage<Void>>) - Method in interface org.eclipse.microprofile.reactive.messaging.Message

Creates a new instance of Message with the given negative-acknowledgement function.

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

Creates a new instance of Message with the specified payload.

A C E G H I M N O S U V W