A B C D E F G H I L M N O P S T U V W 
All Classes All Packages

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
 
alias() - Method in annotation type org.eclipse.microprofile.reactive.messaging.spi.ConnectorAttribute
 

B

BUFFER - org.eclipse.microprofile.reactive.messaging.OnOverflow.Strategy
Buffers all values until the downstream consumes it.
bufferSize() - Method in annotation type org.eclipse.microprofile.reactive.messaging.OnOverflow
 

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
ConnectorLiteral - Class in org.eclipse.microprofile.reactive.messaging.spi
Supports inline instantiation of the Connector qualifier.

D

defaultValue() - Method in annotation type org.eclipse.microprofile.reactive.messaging.spi.ConnectorAttribute
 
deprecated() - Method in annotation type org.eclipse.microprofile.reactive.messaging.spi.ConnectorAttribute
 
description() - Method in annotation type org.eclipse.microprofile.reactive.messaging.spi.ConnectorAttribute
 
direction() - Method in annotation type org.eclipse.microprofile.reactive.messaging.spi.ConnectorAttribute
 
DROP - org.eclipse.microprofile.reactive.messaging.OnOverflow.Strategy
Drops the most recent value if the downstream can't keep up.

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.

F

FAIL - org.eclipse.microprofile.reactive.messaging.OnOverflow.Strategy
Sends an error signal to the downstream subscriber in the case where it can't keep up.

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
 
hidden() - Method in annotation type org.eclipse.microprofile.reactive.messaging.spi.ConnectorAttribute
 

I

Incoming - Annotation Type in org.eclipse.microprofile.reactive.messaging
Used to signify a subscriber to incoming messages.
INCOMING - org.eclipse.microprofile.reactive.messaging.spi.ConnectorAttribute.Direction
Attribute related to an incoming connector, like a deserializer.
INCOMING_AND_OUTGOING - org.eclipse.microprofile.reactive.messaging.spi.ConnectorAttribute.Direction
Attribute used for both directions.
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
 

L

LATEST - org.eclipse.microprofile.reactive.messaging.OnOverflow.Strategy
Keeps only the latest value, dropping any previous value if the downstream can't keep up.

M

mandatory() - Method in annotation type org.eclipse.microprofile.reactive.messaging.spi.ConnectorAttribute
 
MANUAL - org.eclipse.microprofile.reactive.messaging.Acknowledgment.Strategy
Acknowledgment managed by the user code.
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.
name() - Method in annotation type org.eclipse.microprofile.reactive.messaging.spi.ConnectorAttribute
 
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.
NONE - org.eclipse.microprofile.reactive.messaging.Acknowledgment.Strategy
No acknowledgment is performed, neither implicitly or explicitly.
NONE - org.eclipse.microprofile.reactive.messaging.OnOverflow.Strategy
The values are propagated without any back pressure strategy.

O

of(String) - Static method in class org.eclipse.microprofile.reactive.messaging.spi.ConnectorLiteral
Creates a new instance of ConnectorLiteral.
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.
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 - org.eclipse.microprofile.reactive.messaging.spi.ConnectorAttribute.Direction
Attribute related to an outgoing connector, like a serializer.
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.

P

POST_PROCESSING - org.eclipse.microprofile.reactive.messaging.Acknowledgment.Strategy
Acknowledgment performed automatically once the message has been processed.
PRE_PROCESSING - org.eclipse.microprofile.reactive.messaging.Acknowledgment.Strategy
Acknowledgment performed automatically before the processing of the message by the user code.

S

send(M) - Method in interface org.eclipse.microprofile.reactive.messaging.Emitter
Sends a message to the channel.
send(T) - Method in interface org.eclipse.microprofile.reactive.messaging.Emitter
Sends a payload to the channel.

T

THROW_EXCEPTION - org.eclipse.microprofile.reactive.messaging.OnOverflow.Strategy
Causes an IllegalStateException to be thrown by the Emitter.send method if the downstream can't keep up.
type() - Method in annotation type org.eclipse.microprofile.reactive.messaging.spi.ConnectorAttribute
 

U

UNBOUNDED_BUFFER - org.eclipse.microprofile.reactive.messaging.OnOverflow.Strategy
Buffers all values until the downstream consumes it.
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 annotation type org.eclipse.microprofile.reactive.messaging.Acknowledgment
 
value() - Method in annotation type org.eclipse.microprofile.reactive.messaging.Channel
The name of the channel (indicated in the @Outgoing annotation.
value() - Method in annotation type org.eclipse.microprofile.reactive.messaging.Incoming
The name of the consumed channel.
value() - Method in annotation type org.eclipse.microprofile.reactive.messaging.OnOverflow
 
value() - Method in annotation type org.eclipse.microprofile.reactive.messaging.Outgoing
The name of the channel to publish to.
value() - Method in annotation type org.eclipse.microprofile.reactive.messaging.spi.Connector
 
value() - Method in annotation type org.eclipse.microprofile.reactive.messaging.spi.ConnectorAttributes
 
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 B C D E F G H I L M N O P S T U V W 
All Classes All Packages