| Package | Description |
|---|---|
| io.vertx.proton |
= Vert.x Proton
This component facilitates AMQP integrations for Vert.x by providing a thin wrapper around the
link:http://qpid.apache.org/[Apache Qpid] Proton AMQP 1.0 protocol engine.
|
| Modifier and Type | Method and Description |
|---|---|
ProtonSender |
ProtonSession.createSender(String address)
Creates a sender used to send messages to the given node address.
|
ProtonSender |
ProtonConnection.createSender(String address)
Creates a sender used to send messages to the given node address.
|
ProtonSender |
ProtonSender.sendQueueDrainHandler(Handler<ProtonSender> handler)
Sets a handler called when the send queue is not full, i.e.
|
ProtonSender |
ProtonSender.setAutoSettle(boolean autoSettle)
Sets whether sent deliveries should be automatically locally-settled once they have become remotely-settled by the
receiving peer.
|
| Modifier and Type | Method and Description |
|---|---|
ProtonConnection |
ProtonConnection.senderOpenHandler(Handler<ProtonSender> remoteSenderOpenHandler)
Sets a handler for when an AMQP Attach frame is received from the remote peer for a sending link.
|
ProtonSender |
ProtonSender.sendQueueDrainHandler(Handler<ProtonSender> handler)
Sets a handler called when the send queue is not full, i.e.
|
Copyright © 2016. All rights reserved.