Pipeline
Constructor Summary
| Public Constructor | ||
| public |
constructor(_onFail: *) |
|
Method Summary
| Public Methods | ||
| public |
process(msg: Message, onDeliver: Callback) Insert a message in the pipeline queue. |
|
Public Constructors
public constructor(_onFail: *) source
Params:
| Name | Type | Attribute | Description |
| _onFail | * |
Public Methods
public process(msg: Message, onDeliver: Callback) source
Insert a message in the pipeline queue. All messages are wrapped with a PipeContext.
Params:
| Name | Type | Attribute | Description |
| msg | Message | Message for the queue |
|
| onDeliver | Callback | When message is finished processing from all handlers, it will be delivered in this callback. |