Uploaded image for project: 'Apache Storm'
  1. Apache Storm
  2. STORM-386

Development of multilang protocol in nodejs

    XMLWordPrintableJSON

    Details

    • Type: New Feature
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 0.9.3
    • Component/s: storm-multilang
    • Labels:
      None
    • Environment:
      nodejs

      Description

      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).

        Attachments

          Activity

            People

            • Assignee:
              itaifrenkel Itai Frenkel
              Reporter:
              anyatch Anya Tchernishov
            • Votes:
              0 Vote for this issue
              Watchers:
              6 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: