Anya Tchernishov created STORM-386:
--------------------------------------
Summary: Development of multilang protocol in nodejs
Key: STORM-386
URL: https://issues.apache.org/jira/browse/STORM-386
Project: Apache Storm (Incubating)
Issue Type: New Feature
Environment: nodejs
Reporter: Anya Tchernishov
Support nodejs multilang protocol.
Design considerations:
- Emit will receive an object (like args and kwargs in python) and a callback
that is called when task ids list is received.
self.emit({tuple: [word]}, function(taskIds) {
self.log(word + ' sent to task ids - ' + taskIds);
});
- The following methods will received done method that must be invoked on
completion (same pattern used by the mocha test framework for async unit
tests).
- Internal implementation of emit uses Process.stdout.write without a callback
since nodejs streams maintain FIFO order (so far, we have not found a need for
providing a callback).
--
This message was sent by Atlassian JIRA
(v6.2#6252)
