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