API Documentation
Back to top  

AmqpBridge

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

package

Default

Methods

__construct

__construct()

Shuts the bridge down, closing the underlying connection.

close( $arg0) : void

Arguments

$arg0

callable

Creates a Bridge.

create( $arg0,  $arg1 = null) : \io\vertx\jphp\amqpbridge\AmqpBridge
static

param $vertx [Vertx] the vertx instance to use create($vertx)

Creates a Bridge with the given options.

param $vertx [Vertx] the vertx instance to use param $options [AmqpBridgeOptions | array] the options create($vertx, $options)

Arguments

$arg0

Vertx

$arg1

AmqpBridgeOptions | array

Response

\io\vertx\jphp\amqpbridge\AmqpBridge

the (not-yet-started) bridge.

Creates a consumer on the given AMQP address.

createConsumer( $arg0) : \io\vertx\jphp\amqpbridge\MessageConsumer<T>

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.

Arguments

$arg0

string

Response

\io\vertx\jphp\amqpbridge\MessageConsumer

the consumer

Creates a producer to the given AMQP address.

createProducer( $arg0) : \io\vertx\jphp\amqpbridge\MessageProducer<T>

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.

Arguments

$arg0

string

Response

\io\vertx\jphp\amqpbridge\MessageProducer

the producer

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

endHandler( $arg0) : void

Arguments

$arg0

callable

Starts the bridge, establishing the underlying connection.

start( $arg0,  $arg1,  $arg2,  $arg3 = null,  $arg4 = null) : void

param $hostname [string] the host name to connect to param $port [integer] the port to connect to param $resultHandler [callable] the result handler start($hostname, $port, $resultHandler)

Starts the bridge, establishing the underlying connection.

param $hostname [string] the host name to connect to param $port [integer] the port to connect to param $username [string] the username param $password [string] the password param $resultHandler [callable] the result handler start($hostname, $port, $username, $password, $resultHandler)

Arguments

$arg0

string

$arg1

integer

$arg2

callable | string

$arg3

string

$arg4

callable