vertx / io.vertx.reactivex.amqpbridge / AmqpBridge

# AmqpBridge

`open class AmqpBridge`

Vert.x AMQP Bridge. Facilitates sending and receiving AMQP 1.0 messages. NOTE: This class has been automatically generated from the io.vertx.amqpbridge.AmqpBridge non RX-ified interface using Vert.x codegen.

### Constructors

<init> | `AmqpBridge(delegate: AmqpBridge)`

### Properties

__TYPE_ARG | `static val __TYPE_ARG: TypeArg<AmqpBridge>`

### Functions

close | `open 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 | `open 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 | `open 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 | `open fun endHandler(endHandler: Handler<Void>): Unit` Set an end handler. This will fire if the underlying connection is unexpectedly disconnected or remotely closed.
equals | `open fun equals(other: Any?): Boolean`
getDelegate | `open fun getDelegate(): AmqpBridge`
hashCode | `open fun hashCode(): Int`
newInstance | `open static fun newInstance(arg: AmqpBridge): AmqpBridge`
rxClose | `open fun rxClose(): Completable` Shuts the bridge down, closing the underlying connection.
rxStart | `open fun rxStart(hostname: String, port: Int, username: String, password: String): Single<AmqpBridge>` `open fun rxStart(hostname: String, port: Int): Single<AmqpBridge>` Starts the bridge, establishing the underlying connection.
start | `open fun start(hostname: String, port: Int, username: String, password: String, resultHandler: Handler<AsyncResult<AmqpBridge>>): Unit` `open fun start(hostname: String, port: Int, resultHandler: Handler<AsyncResult<AmqpBridge>>): Unit` Starts the bridge, establishing the underlying connection.
toString | `open fun toString(): String`