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 |
---|---|
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.
|
Modifier and Type | Method and 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.
|
Copyright © 2018–2019 Eclipse Foundation. All rights reserved.