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