[GitHub] storm pull request #2241: STORM-2306 : Messaging subsystem redesign.

[roshannaik]

Github user roshannaik commented on a diff in the pull request:

    https://github.com/apache/storm/pull/2241#discussion_r158931433
  
    --- Diff: storm-client/src/jvm/org/apache/storm/task/IOutputCollector.java 
---
    @@ -30,4 +31,5 @@
         void ack(Tuple input);
         void fail(Tuple input);
         void resetTimeout(Tuple input);
    +    void flush();
    --- End diff --
    
    do we support end users writing custom output collectors ? This is public 
for internal use only I think. 
    Right, there was no easy alternative.


---