Uses of Interface
org.eclipse.microprofile.reactive.messaging.Message
-
Packages that use Message 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 -
-
Uses of Message in org.eclipse.microprofile.reactive.messaging
Methods in org.eclipse.microprofile.reactive.messaging with type parameters of type Message Modifier and Type Method Description <M extends Message<? extends T>>
voidEmitter. send(M msg)
Sends a message to the channel.Methods in org.eclipse.microprofile.reactive.messaging that return Message Modifier and Type Method 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 ofMessage
with the given acknowledgement supplier.default Message<T>
Message. withNack(Function<Throwable,CompletionStage<Void>> nack)
Creates a new instance ofMessage
with the given negative-acknowledgement function.default <P> Message<P>
Message. withPayload(P payload)
Creates a new instance ofMessage
with the specified payload. -
Uses of Message in org.eclipse.microprofile.reactive.messaging.spi
Methods in org.eclipse.microprofile.reactive.messaging.spi that return types with arguments of type Message Modifier and Type Method Description PublisherBuilder<? extends Message<?>>
IncomingConnectorFactory. getPublisherBuilder(Config config)
Creates a channel for the given configuration.SubscriberBuilder<? extends Message<?>,Void>
OutgoingConnectorFactory. getSubscriberBuilder(Config config)
Creates a channel for the given configuration.
-