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 ofMessagewith the given acknowledgement supplier.default Message<T>Message. withNack(Function<Throwable,CompletionStage<Void>> nack)Creates a new instance ofMessagewith the given negative-acknowledgement function.default <P> Message<P>Message. withPayload(P payload)Creates a new instance ofMessagewith 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.
-