vertx / io.vertx.amqpbridge / AmqpBridge

AmqpBridge

interface AmqpBridge

Vert.x AMQP Bridge. Facilitates sending and receiving AMQP 1.0 messages.

Functions

close

abstract fun close(resultHandler: Handler<AsyncResult<Void>>): Unit

Shuts the bridge down, closing the underlying connection.

create

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.

createConsumer

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.

createProducer

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.

endHandler

abstract fun endHandler(endHandler: Handler<Void>): Unit

Set an end handler. This will fire if the underlying connection is unexpectedly disconnected or remotely closed.

start

abstract fun start(hostname: String, port: Int, username: String, password: String, resultHandler: Handler<AsyncResult<AmqpBridge>>): Unit
abstract fun start(hostname: String, port: Int, resultHandler: Handler<AsyncResult<AmqpBridge>>): Unit

Starts the bridge, establishing the underlying connection.