incubator-s4-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Karthik Kambatla <>
Subject Re: [jira] [Created] (S4-6) Netty initialization
Date Thu, 20 Oct 2011 06:19:27 GMT
Hi Bruce,

Currently, the NettyEmitter creates all the connections and stores the
corresponding channels to be later used by send() calls. The issue seems to
be that the send() calls don't wait for the connections to be formed. If the
required connection doesn't exist, the message is dropped.

Understandably, the fix would be to have the send() block till the required
connection is made. In that case, we might as well create the connections
lazily (on first send). That way, the connections will be automatically
repaired, in case they break, by subsequent send() invocations.

Let me know what you think.


On Wed, Oct 12, 2011 at 1:51 PM, Leo Neumeyer (Created) (JIRA) <> wrote:

> Netty initialization
> --------------------
>                 Key: S4-6
>                 URL:
>             Project: Apache S4
>          Issue Type: Improvement
>            Reporter: Leo Neumeyer
> Wait for Netty layer to be ready before the app init method is called.
> --
> This message is automatically generated by JIRA.
> If you think it was sent incorrectly, please contact your JIRA
> administrators:
> For more information on JIRA, see:

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message