Package | Description |
---|---|
org.eclipse.microprofile.reactive.messaging |
The MicroProfile Reactive Messaging API.
|
org.eclipse.microprofile.reactive.messaging.spi |
The MicroProfile Reactive Messaging API Connector SPI
|
Modifier and Type | Method and Description |
---|---|
<M extends Message<? extends T>> |
Emitter.send(M msg)
Sends a message to the channel.
|
Modifier and Type | Method and Description |
---|---|
static <T> Message<T> |
Message.of(T payload)
Create a message with the given payload.
|
static <T> Message<T> |
Message.of(T payload,
Supplier<CompletionStage<Void>> ack)
Create a message with the given payload and ack function.
|
static <T> Message<T> |
Message.of(T payload,
Supplier<CompletionStage<Void>> ack,
Function<Throwable,CompletionStage<Void>> nack)
Create a message with the given payload, ack and nack functions.
|
default Message<T> |
Message.withAck(Supplier<CompletionStage<Void>> ack)
Creates a new instance of
Message with the given acknowledgement supplier. |
default Message<T> |
Message.withNack(Function<Throwable,CompletionStage<Void>> nack)
Creates a new instance of
Message with the given negative-acknowledgement function. |
default <P> Message<P> |
Message.withPayload(P payload)
Creates a new instance of
Message with the specified payload. |
Modifier and Type | Method and Description |
---|---|
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> |
IncomingConnectorFactory.getPublisherBuilder(Config config)
Creates a channel for the given configuration.
|
org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void> |
OutgoingConnectorFactory.getSubscriberBuilder(Config config)
Creates a channel for the given configuration.
|
Copyright © 2018 – 2021 Eclipse Foundation. All rights reserved.
Use is subject to license terms.