MessageProducer

Represents a stream of message that can be written to.

package

Default

Methods

__construct

__construct() 

address

address() : string

Response

string

The address to which the producer produces messages.

Same as @see \io\vertx\jphp\core\eventbus\MessageProducer::close but with an <code>handler</code> called when the operation completes

close( $arg0) : void

Arguments

$arg0

callable

Update the delivery options of this producer.

deliveryOptions( $arg0) : $this

Arguments

$arg0

array

Response

$this

this producer object

drainHandler

drainHandler( $arg0) : $this

Arguments

$arg0

callable

Response

$this

Closes the producer, calls @see \io\vertx\jphp\core\eventbus\MessageProducer::close

end( $arg0,  $arg1 = null) : void

param $handler [callable] end($handler)

Same as but with an handler called when the operation completes

param $data [mixed] param $handler [callable] end($data, $handler)

Arguments

$arg0

callable | mixed

$arg1

callable

exceptionHandler

exceptionHandler( $arg0) : $this

Arguments

$arg0

callable

Response

$this

setWriteQueueMaxSize

setWriteQueueMaxSize( $arg0) : $this

Arguments

$arg0

integer

Response

$this

Same as but with an <code>handler</code> called when the operation completes

write( $arg0,  $arg1) : void

Arguments

$arg0

mixed

$arg1

callable

This will return <code>true</code> if there are more bytes in the write queue than the value set using @see \io\vertx\jphp\core\eventbus\MessageProducer::setWriteQueueMaxSize

writeQueueFull() : boolean

Response

boolean

true if write queue is full

Constants

DEFAULT_WRITE_QUEUE_MAX_SIZE

DEFAULT_WRITE_QUEUE_MAX_SIZE
var

php文件只是为了写代码方便,常量的实际值请参考原java文件