Mailing-List: contact dev-help@storm.incubator.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@storm.incubator.apache.org
Date: Thu, 3 Jul 2014 15:10:25 +0000 (UTC)
From: "Anya Tchernishov (JIRA)" <jira@apache.org>
To: dev@storm.incubator.apache.org
Message-ID: <JIRA.12725283.1404400058582.97972.1404400225126@arcas>
In-Reply-To: <JIRA.12725283.1404400058582@arcas>
References: <JIRA.12725283.1404400058582@arcas>
Subject: [jira] [Commented] (STORM-386) Development of multilang protocol in
 nodejs
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit


    [ https://issues.apache.org/jira/browse/STORM-386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14051555#comment-14051555 ] 

Anya Tchernishov commented on STORM-386:
----------------------------------------

Pull request https://github.com/apache/incubator-storm/pull/177

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