AMQP Sender interface used to send messages.
package |
Default |
---|
__construct()
address() : string
string
the configured address.
close( $arg0) : void
callable
connection() : \io\vertx\jphp\amqp\AmqpConnection
drainHandler( $arg0) : $this
The stream implementation defines when the drain handler, for example it could be when the queue size has been
reduced to maxSize / 2
.
callable
$this
a reference to this, so the API can be used fluently
end( $arg0, $arg1 = null) : void
param $handler [callable] end($handler)
Same as but with an handler
called when the operation completes
param $data [AmqpMessage] param $handler [callable] end($data, $handler)
callable | AmqpMessage
callable
exceptionHandler( $arg0) : $this
callable
$this
send( $arg0) : $this
AmqpMessage
$this
the current sender
sendWithAck( $arg0, $arg1) : $this
AmqpMessage
callable
$this
the current sender
setWriteQueueMaxSize( $arg0) : $this
integer
$this
write( $arg0, $arg1) : void
AmqpMessage
callable
writeQueueFull() : boolean
boolean
true if write queue is full