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