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