Represents a stream of message that can be written to.
package |
Default |
---|
__construct()
address() : string
string
The address to which the producer produces messages.
close( $arg0) : void
callable
deliveryOptions( $arg0) : $this
array
$this
this producer object
drainHandler( $arg0) : $this
callable
$this
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)
callable | mixed
callable
exceptionHandler( $arg0) : $this
callable
$this
setWriteQueueMaxSize( $arg0) : $this
integer
$this
write( $arg0, $arg1) : void
mixed
callable
writeQueueFull() : boolean
boolean
true if write queue is full
DEFAULT_WRITE_QUEUE_MAX_SIZE
var |
php文件只是为了写代码方便,常量的实际值请参考原java文件 |
---|