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.