Class: MessageProducer

vertx-js/message_producer~ MessageProducer

new MessageProducer()

Represents a stream of message that can be written to.

Source:

Methods

address() → {string}

Source:
Returns:
The address to which the producer produces messages.
Type
string

close()

Closes the producer, this method should be called when the message producer is not used anymore.
Source:

deliveryOptions(options) → {MessageProducer}

Update the delivery options of this producer.
Parameters:
Name Type Description
options Object the new options
Source:
Returns:
this producer object
Type
MessageProducer

drainHandler(handler) → {MessageProducer}

Parameters:
Name Type Description
handler function
Source:
Returns:
Type
MessageProducer

end(t)

Same as MessageProducer#end but writes some data to the stream before ending.
Parameters:
Name Type Description
t Object
Source:

exceptionHandler(handler) → {MessageProducer}

Parameters:
Name Type Description
handler function
Source:
Returns:
Type
MessageProducer

send(message, replyHandler) → {MessageProducer}

Parameters:
Name Type Description
message Object
replyHandler function
Source:
Returns:
Type
MessageProducer

setWriteQueueMaxSize(maxSize) → {MessageProducer}

Parameters:
Name Type Description
maxSize number
Source:
Returns:
Type
MessageProducer

write(data) → {MessageProducer}

Parameters:
Name Type Description
data Object
Source:
Returns:
Type
MessageProducer

writeQueueFull() → {boolean}

This will return true if there are more bytes in the write queue than the value set using MessageProducer#setWriteQueueMaxSize
Source:
Returns:
true if write queue is full
Type
boolean