Interface used to consume AMQP message as a stream of message.
Back pressure is implemented using AMQP credits.
package |
Default |
---|
__construct()
address() : string
string
the address, not {@code null}
close( $arg0) : void
callable
connection() : \io\vertx\jphp\amqp\AmqpConnection
endHandler( $arg0) : $this
callable
$this
exceptionHandler( $arg0) : $this
callable
$this
fetch( $arg0) : $this
integer
$this
handler( $arg0) : $this
callable
$this
pause() : $this
$this
pipe() : \io\vertx\jphp\amqp\Pipe<AmqpMessage>
The stream will be resumed when the pipe will be wired to a WriteStream
.
\io\vertx\jphp\amqp\Pipe
a pipe
pipeTo( $arg0, $arg1) : void
Elements emitted by this stream will be written to the write stream until this stream ends or fails.
Once this stream has ended or failed, the write stream will be ended and the handler
will be
called with the result.
WriteStream
callable
resume() : $this
$this