Represents a stream of message that can be written to.
| package |
Default |
|---|
__construct()
address() : string
stringThe address to which the producer produces messages.
close( $arg0 = null) : void
close()
Same as @see \io\vertx\jphp\core\eventbus\MessageProducer::close but with an handler called when the operation completes
param $handler [callable] close($handler)
callable
deliveryOptions( $arg0) : $this
array | DeliveryOptions
$thisthis producer object
drainHandler( $arg0) : $this
callable
$this
end( $arg0 = null, $arg1 = null) : void
end()
Same as @see \io\vertx\jphp\core\eventbus\MessageProducer::end but writes some data to the stream before ending.
param $data [mixed] the data to write end($data)
Closes the producer, calls @see \io\vertx\jphp\core\eventbus\MessageProducer::close
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)
callable | mixed
callable
exceptionHandler( $arg0) : $this
callable
$this
send( $arg0, $arg1 = null) : \io\vertx\jphp\core\eventbus\MessageProducer<T>
param $message [mixed] the message to send
this method is deprecated
send($message)
Like @see \io\vertx\jphp\core\eventbus\MessageProducer::send but specifying a replyHandler that will be called if the recipient
subsequently replies to the message.
param $message [mixed] the message to send
param $replyHandler [callable] reply handler will be called when any reply from the recipient is received, may be {@code null}
this method is deprecated
send($message, $replyHandler)
| deprecated |
|---|
mixed
callable
\io\vertx\jphp\core\eventbus\MessageProducerreference to this for fluency
setWriteQueueMaxSize( $arg0) : $this
integer
$this
write( $arg0, $arg1 = null) : $this
param $data [mixed] param $handler [callable] write($data, $handler)
mixed
callable
$this
writeQueueFull() : boolean
booleantrue if write queue is full
DEFAULT_WRITE_QUEUE_MAX_SIZE
| var |
php文件只是为了写代码方便,常量的实际值请参考原java文件 |
|---|