Package | Description |
---|---|
io.vertx.proton.streams |
Modifier and Type | Method and Description |
---|---|
static Tracker |
Tracker.create(org.apache.qpid.proton.message.Message message)
Creates a tracker for sending a message.
|
static Tracker |
Tracker.create(org.apache.qpid.proton.message.Message message,
io.vertx.core.Handler<Tracker> onUpdated)
Creates a tracker for sending a message, providing a handler that is
called when disposition updates are received for the message delivery.
|
Modifier and Type | Method and Description |
---|---|
static ProtonSubscriber<Tracker> |
ProtonStreams.createTrackerProducer(ProtonConnection connection,
String address)
Creates an AMQP producer, presented as a reactive streams
Subscriber . |
static ProtonSubscriber<Tracker> |
ProtonStreams.createTrackerProducer(ProtonConnection connection,
String address,
ProtonSubscriberOptions options)
Creates an AMQP producer, presented as a reactive streams
Subscriber . |
Modifier and Type | Method and Description |
---|---|
static Tracker |
Tracker.create(org.apache.qpid.proton.message.Message message,
io.vertx.core.Handler<Tracker> onUpdated)
Creates a tracker for sending a message, providing a handler that is
called when disposition updates are received for the message delivery.
|
Copyright © 2022 Eclipse. All rights reserved.