A B C D E F G H I L M N O P S T U V W
All Classes All Packages
All Classes All Packages
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
-
Parent class for
IncomingConnectorFactory
andOutgoingConnectorFactory
. - 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 theEmitter.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.
All Classes All Packages