interface AmqpBridge
Vert.x AMQP Bridge. Facilitates sending and receiving AMQP 1.0 messages.
abstract fun close(resultHandler: Handler<AsyncResult<Void>>): Unit
Shuts the bridge down, closing the underlying connection. |
|
open static fun create(vertx: Vertx): AmqpBridge
Creates a Bridge. open static fun create(vertx: Vertx, options: AmqpBridgeOptions): AmqpBridge
Creates a Bridge with the given options. |
|
abstract fun <T : Any> createConsumer(amqpAddress: String): MessageConsumer<T>
Creates a consumer on the given AMQP address. This method MUST be called from the bridge Context thread, as used in the result handler callback from the start methods. The bridge MUST be successfully started before the method is called. |
|
abstract fun <T : Any> createProducer(amqpAddress: String): MessageProducer<T>
Creates a producer to the given AMQP address. This method MUST be called from the bridge Context thread, as used in the result handler callback from the start methods. The bridge MUST be successfully started before the method is called. |
|
abstract fun endHandler(endHandler: Handler<Void>): Unit
Set an end handler. This will fire if the underlying connection is unexpectedly disconnected or remotely closed. |
|
abstract fun start(hostname: String, port: Int, username: String, password: String, resultHandler: Handler<AsyncResult<AmqpBridge>>): Unitabstract fun start(hostname: String, port: Int, resultHandler: Handler<AsyncResult<AmqpBridge>>): Unit
Starts the bridge, establishing the underlying connection. |