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

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

exceptionHandler(handler) → {MessageProducer}

Parameters:
Name Type Description
handler 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