[akka-user] Re: Connection reset by peer in Akka Streams RC2

2015-06-02 Thread Russell Cohen
It's probably worth mentioning that this isn't a regression, it was also 
happening in M2 and persisted when we upgraded.

On Tuesday, June 2, 2015 at 7:05:09 PM UTC-7, Russell Cohen wrote:
>
> Hi All,
>   We've been trying to debug a tricky intermittent failure mode we're 
> having with akka-streams. We are setting up a large fan in (~32 nodes) and 
> periodically one of the nodes will inexplicably lead to an RST packet being 
> sent, aborting the entire graph. Below, I have debug logging from the 
> fan-in master as well as from the child that sent the failing packet along 
> with my commentary:
>
>
> Fan in master:
>
> [DEBUG] [06/02/2015 18:13:09.228] [nrt-akka.actor.default-dispatcher-25] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Attempting 
> connection to [long-nrt-20/IP_REDACTED:2552]
> [DEBUG] [06/02/2015 18:13:09.229] [nrt-akka.actor.default-dispatcher-19] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Connection 
> established to [long-nrt-20/IP_REDACTED:2552]
> [DEBUG] [06/02/2015 18:13:09.230] [nrt-akka.actor.default-dispatcher-25] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] 
> [Actor[akka://nrt/system/IO-TCP-STREAM/client-127-long-nrt-20%2IP_REDACTED%3A2552#-368113801]]
>  
> registered as connection handler
> [DEBUG] [06/02/2015 18:13:09.230] [nrt-akka.actor.default-dispatcher-20] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Wrote [8] 
> bytes to channel
> [DEBUG] [06/02/2015 18:13:09.230] [nrt-akka.actor.default-dispatcher-20] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Got 
> ConfirmedClose command, sending FIN.
> [DEBUG] [06/02/2015 18:13:09.324] [nrt-akka.actor.default-dispatcher-20] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read 
> [7695] bytes.
> [DEBUG] [06/02/2015 18:13:09.324] [nrt-akka.actor.default-dispatcher-25] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read 
> [9545] bytes.
> [DEBUG] [06/02/2015 18:13:09.325] [nrt-akka.actor.default-dispatcher-23] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read 
> [1794] bytes.
> [DEBUG] [06/02/2015 18:13:09.325] [nrt-akka.actor.default-dispatcher-20] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read 
> [1794] bytes.
> [DEBUG] [06/02/2015 18:13:09.333] [nrt-akka.actor.default-dispatcher-25] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read 
> [12439] bytes.
> [DEBUG] [06/02/2015 18:13:09.340] [nrt-akka.actor.default-dispatcher-20] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read 
> [1566] bytes.
> [DEBUG] [06/02/2015 18:13:09.346] [nrt-akka.actor.default-dispatcher-2] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read 
> [5210] bytes.
> [DEBUG] [06/02/2015 18:13:09.346] [nrt-akka.actor.default-dispatcher-20] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read 
> [4344] bytes.
> (snip)
> [DEBUG] [06/02/2015 18:13:24.800] [nrt-akka.actor.default-dispatcher-27] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read 
> [131072] bytes.
> [DEBUG] [06/02/2015 18:13:24.800] [nrt-akka.actor.default-dispatcher-27] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read 
> [131072] bytes.
> [DEBUG] [06/02/2015 18:13:25.066] [nrt-akka.actor.default-dispatcher-23] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read 
> [131072] bytes.
> [DEBUG] [06/02/2015 18:13:25.066] [nrt-akka.actor.default-dispatcher-23] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read 
> [131072] bytes.
> [DEBUG] [06/02/2015 18:13:25.302] [nrt-akka.actor.default-dispatcher-24] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read 
> [131072] bytes.
> [DEBUG] [06/02/2015 18:13:25.302] [nrt-akka.actor.default-dispatcher-24] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read 
> [131072] bytes.
> [DEBUG] [06/02/2015 18:13:31.169] [nrt-akka.actor.default-dispatcher-23] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read 
> [131072] bytes.
> [DEBUG] [06/02/2015 18:13:31.170] [nrt-akka.actor.default-dispatcher-3] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read 
> [105496] bytes.
> [DEBUG] [06/02/2015 18:13:31.911] [nrt-akka.actor.default-dispatcher-2] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Closing 
> connection due to IO error java.io.IOException: Connection reset by peer
> (Abort message propagates to other streams)
>
> Fan in failing slave:
> [DEBUG] [06/02/2015 18:13:09.230] [nrt-akka.actor.default-dispatcher-26] [
> akka.tcp://nrt@long-nrt-20:2551/system/IO-TCP/selectors/$a/10] 
> [Actor[akka://nrt/system/IO-TCP-STREAM/server-1-long-nrt-20%2FIP_REDACTED%3A2552/$j#733080811]]
>  
> registered as connection handler
> [DEBUG] [06/02/2015 18:13:09.230] [nrt-akka.actor.default-dispatcher-25] [
> akka.tcp://nrt@long-nrt-20:

[akka-user] Re: Connection reset by peer in Akka Streams RC2

2015-06-03 Thread Russell Cohen
One thing that I've discovered while debugging this is that if you throw an 
exception in onPull the same behavior seems to happen...I'd almost consider 
it a bug that an exception thrown in a PushPull stage is silently 
dropped...I would at least expect a behavior like that to be called out in 
the docs. Perhaps an "AutofailingPushPullStag" or something that wraps the 
methods in a `try` and ctx.fails if there's an error?

Russell


On Tuesday, June 2, 2015 at 7:05:09 PM UTC-7, Russell Cohen wrote:
>
> Hi All,
>   We've been trying to debug a tricky intermittent failure mode we're 
> having with akka-streams. We are setting up a large fan in (~32 nodes) and 
> periodically one of the nodes will inexplicably lead to an RST packet being 
> sent, aborting the entire graph. Below, I have debug logging from the 
> fan-in master as well as from the child that sent the failing packet along 
> with my commentary:
>
>
> Fan in master:
>
> [DEBUG] [06/02/2015 18:13:09.228] [nrt-akka.actor.default-dispatcher-25] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Attempting 
> connection to [long-nrt-20/IP_REDACTED:2552]
> [DEBUG] [06/02/2015 18:13:09.229] [nrt-akka.actor.default-dispatcher-19] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Connection 
> established to [long-nrt-20/IP_REDACTED:2552]
> [DEBUG] [06/02/2015 18:13:09.230] [nrt-akka.actor.default-dispatcher-25] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] 
> [Actor[akka://nrt/system/IO-TCP-STREAM/client-127-long-nrt-20%2IP_REDACTED%3A2552#-368113801]]
>  
> registered as connection handler
> [DEBUG] [06/02/2015 18:13:09.230] [nrt-akka.actor.default-dispatcher-20] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Wrote [8] 
> bytes to channel
> [DEBUG] [06/02/2015 18:13:09.230] [nrt-akka.actor.default-dispatcher-20] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Got 
> ConfirmedClose command, sending FIN.
> [DEBUG] [06/02/2015 18:13:09.324] [nrt-akka.actor.default-dispatcher-20] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read 
> [7695] bytes.
> [DEBUG] [06/02/2015 18:13:09.324] [nrt-akka.actor.default-dispatcher-25] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read 
> [9545] bytes.
> [DEBUG] [06/02/2015 18:13:09.325] [nrt-akka.actor.default-dispatcher-23] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read 
> [1794] bytes.
> [DEBUG] [06/02/2015 18:13:09.325] [nrt-akka.actor.default-dispatcher-20] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read 
> [1794] bytes.
> [DEBUG] [06/02/2015 18:13:09.333] [nrt-akka.actor.default-dispatcher-25] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read 
> [12439] bytes.
> [DEBUG] [06/02/2015 18:13:09.340] [nrt-akka.actor.default-dispatcher-20] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read 
> [1566] bytes.
> [DEBUG] [06/02/2015 18:13:09.346] [nrt-akka.actor.default-dispatcher-2] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read 
> [5210] bytes.
> [DEBUG] [06/02/2015 18:13:09.346] [nrt-akka.actor.default-dispatcher-20] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read 
> [4344] bytes.
> (snip)
> [DEBUG] [06/02/2015 18:13:24.800] [nrt-akka.actor.default-dispatcher-27] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read 
> [131072] bytes.
> [DEBUG] [06/02/2015 18:13:24.800] [nrt-akka.actor.default-dispatcher-27] [
> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read 
> [131072] bytes.
> [DEBUG] [06/02/2015 18:
> ...

-- 
>>  Read the docs: http://akka.io/docs/
>>  Check the FAQ: 
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>  Search the archives: https://groups.google.com/group/akka-user
--- 
You received this message because you are subscribed to the Google Groups "Akka 
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.


Re: [akka-user] Re: Connection reset by peer in Akka Streams RC2

2015-06-03 Thread Endre Varga
Whithout looking at your stream code it is hard to tell. Can you prepare a
very simple reproducer?

-Endre

On Wed, Jun 3, 2015 at 4:09 AM, Russell Cohen  wrote:

> It's probably worth mentioning that this isn't a regression, it was also
> happening in M2 and persisted when we upgraded.
>
>
> On Tuesday, June 2, 2015 at 7:05:09 PM UTC-7, Russell Cohen wrote:
>
>> Hi All,
>>   We've been trying to debug a tricky intermittent failure mode we're
>> having with akka-streams. We are setting up a large fan in (~32 nodes) and
>> periodically one of the nodes will inexplicably lead to an RST packet being
>> sent, aborting the entire graph. Below, I have debug logging from the
>> fan-in master as well as from the child that sent the failing packet along
>> with my commentary:
>>
>>
>> Fan in master:
>>
>> [DEBUG] [06/02/2015 18:13:09.228] [nrt-akka.actor.default-dispatcher-25]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143]
>> Attempting connection to [long-nrt-20/IP_REDACTED:2552]
>> [DEBUG] [06/02/2015 18:13:09.229] [nrt-akka.actor.default-dispatcher-19]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143]
>> Connection established to [long-nrt-20/IP_REDACTED:2552]
>> [DEBUG] [06/02/2015 18:13:09.230] [nrt-akka.actor.default-dispatcher-25]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143]
>> [Actor[akka://nrt/system/IO-TCP-STREAM/client-127-long-nrt-20%2IP_REDACTED%3A2552#-368113801]]
>> registered as connection handler
>> [DEBUG] [06/02/2015 18:13:09.230] [nrt-akka.actor.default-dispatcher-20]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Wrote
>> [8] bytes to channel
>> [DEBUG] [06/02/2015 18:13:09.230] [nrt-akka.actor.default-dispatcher-20]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Got
>> ConfirmedClose command, sending FIN.
>> [DEBUG] [06/02/2015 18:13:09.324] [nrt-akka.actor.default-dispatcher-20]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read
>> [7695] bytes.
>> [DEBUG] [06/02/2015 18:13:09.324] [nrt-akka.actor.default-dispatcher-25]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read
>> [9545] bytes.
>> [DEBUG] [06/02/2015 18:13:09.325] [nrt-akka.actor.default-dispatcher-23]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read
>> [1794] bytes.
>> [DEBUG] [06/02/2015 18:13:09.325] [nrt-akka.actor.default-dispatcher-20]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read
>> [1794] bytes.
>> [DEBUG] [06/02/2015 18:13:09.333] [nrt-akka.actor.default-dispatcher-25]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read
>> [12439] bytes.
>> [DEBUG] [06/02/2015 18:13:09.340] [nrt-akka.actor.default-dispatcher-20]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read
>> [1566] bytes.
>> [DEBUG] [06/02/2015 18:13:09.346] [nrt-akka.actor.default-dispatcher-2] [
>> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read
>> [5210] bytes.
>> [DEBUG] [06/02/2015 18:13:09.346] [nrt-akka.actor.default-dispatcher-20]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read
>> [4344] bytes.
>> (snip)
>> [DEBUG] [06/02/2015 18:13:24.800] [nrt-akka.actor.default-dispatcher-27]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read
>> [131072] bytes.
>> [DEBUG] [06/02/2015 18:13:24.800] [nrt-akka.actor.default-dispatcher-27]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read
>> [131072] bytes.
>> [DEBUG] [06/02/2015 18:13:25.066] [nrt-akka.actor.default-dispatcher-23]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read
>> [131072] bytes.
>> [DEBUG] [06/02/2015 18:13:25.066] [nrt-akka.actor.default-dispatcher-23]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read
>> [131072] bytes.
>> [DEBUG] [06/02/2015 18:13:25.302] [nrt-akka.actor.default-dispatcher-24]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read
>> [131072] bytes.
>> [DEBUG] [06/02/2015 18:13:25.302] [nrt-akka.actor.default-dispatcher-24]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read
>> [131072] bytes.
>> [DEBUG] [06/02/2015 18:13:31.169] [nrt-akka.actor.default-dispatcher-23]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read
>> [131072] bytes.
>> [DEBUG] [06/02/2015 18:13:31.170] [nrt-akka.actor.default-dispatcher-3] [
>> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read
>> [105496] bytes.
>> [DEBUG] [06/02/2015 18:13:31.911] [nrt-akka.actor.default-dispatcher-2] [
>> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Closing
>> connection due to IO error java.io.IOException: Connection reset by peer
>> (Abort message propagates to other streams)
>>
>> Fan in failing slave:
>> [DEBUG] [06/02/2015 18:13:09.230] [nrt-akka.actor.default-dispatcher-26]
>> [akka.tcp://nrt@long-nrt-20:2551/system/IO-TCP/selectors/$a/10]
>> [Actor[akka://nrt/system/IO-TCP-STREA

Re: [akka-user] Re: Connection reset by peer in Akka Streams RC2

2015-06-04 Thread Endre Varga
Hi Russel,

On Thu, Jun 4, 2015 at 2:03 AM, Russell Cohen  wrote:

> One thing that I've discovered while debugging this is that if you throw
> an exception in onPull the same behavior seems to happen...I'd almost
> consider it a bug that an exception thrown in a PushPull stage is silently
> dropped...
>

It is not dropped, it is converted to an onError signal in the underlying
stream. Once it reaches the TCP flow, the error signal will force TCP to
abort the connection.

-Endre


> I would at least expect a behavior like that to be called out in the docs.
> Perhaps an "AutofailingPushPullStag" or something that wraps the methods in
> a `try` and ctx.fails if there's an error?
>
> Russell
>
>
> On Tuesday, June 2, 2015 at 7:05:09 PM UTC-7, Russell Cohen wrote:
>>
>> Hi All,
>>   We've been trying to debug a tricky intermittent failure mode we're
>> having with akka-streams. We are setting up a large fan in (~32 nodes) and
>> periodically one of the nodes will inexplicably lead to an RST packet being
>> sent, aborting the entire graph. Below, I have debug logging from the
>> fan-in master as well as from the child that sent the failing packet along
>> with my commentary:
>>
>>
>> Fan in master:
>>
>> [DEBUG] [06/02/2015 18:13:09.228] [nrt-akka.actor.default-dispatcher-25]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143]
>> Attempting connection to [long-nrt-20/IP_REDACTED:2552]
>> [DEBUG] [06/02/2015 18:13:09.229] [nrt-akka.actor.default-dispatcher-19]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143]
>> Connection established to [long-nrt-20/IP_REDACTED:2552]
>> [DEBUG] [06/02/2015 18:13:09.230] [nrt-akka.actor.default-dispatcher-25]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143]
>> [Actor[akka://nrt/system/IO-TCP-STREAM/client-127-long-nrt-20%2IP_REDACTED%3A2552#-368113801]]
>> registered as connection handler
>> [DEBUG] [06/02/2015 18:13:09.230] [nrt-akka.actor.default-dispatcher-20]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Wrote
>> [8] bytes to channel
>> [DEBUG] [06/02/2015 18:13:09.230] [nrt-akka.actor.default-dispatcher-20]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Got
>> ConfirmedClose command, sending FIN.
>> [DEBUG] [06/02/2015 18:13:09.324] [nrt-akka.actor.default-dispatcher-20]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read
>> [7695] bytes.
>> [DEBUG] [06/02/2015 18:13:09.324] [nrt-akka.actor.default-dispatcher-25]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read
>> [9545] bytes.
>> [DEBUG] [06/02/2015 18:13:09.325] [nrt-akka.actor.default-dispatcher-23]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read
>> [1794] bytes.
>> [DEBUG] [06/02/2015 18:13:09.325] [nrt-akka.actor.default-dispatcher-20]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read
>> [1794] bytes.
>> [DEBUG] [06/02/2015 18:13:09.333] [nrt-akka.actor.default-dispatcher-25]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read
>> [12439] bytes.
>> [DEBUG] [06/02/2015 18:13:09.340] [nrt-akka.actor.default-dispatcher-20]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read
>> [1566] bytes.
>> [DEBUG] [06/02/2015 18:13:09.346] [nrt-akka.actor.default-dispatcher-2] [
>> akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read
>> [5210] bytes.
>> [DEBUG] [06/02/2015 18:13:09.346] [nrt-akka.actor.default-dispatcher-20]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read
>> [4344] bytes.
>> (snip)
>> [DEBUG] [06/02/2015 18:13:24.800] [nrt-akka.actor.default-dispatcher-27]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read
>> [131072] bytes.
>> [DEBUG] [06/02/2015 18:13:24.800] [nrt-akka.actor.default-dispatcher-27]
>> [akka.tcp://nrt@long-nrt-1:2551/system/IO-TCP/selectors/$a/143] Read
>> [131072] bytes.
>> [DEBUG] [06/02/2015 18:
>> ...
>
>  --
> >> Read the docs: http://akka.io/docs/
> >> Check the FAQ:
> http://doc.akka.io/docs/akka/current/additional/faq.html
> >> Search the archives: https://groups.google.com/group/akka-user
> ---
> You received this message because you are subscribed to the Google Groups
> "Akka User List" group.
> To unsubscribe from this group and stop receiving emails from it, send an
> email to akka-user+unsubscr...@googlegroups.com.
> To post to this group, send email to akka-user@googlegroups.com.
> Visit this group at http://groups.google.com/group/akka-user.
> For more options, visit https://groups.google.com/d/optout.
>

-- 
>>  Read the docs: http://akka.io/docs/
>>  Check the FAQ: 
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>  Search the archives: https://groups.google.com/group/akka-user
--- 
You received this message because you are subscribed to the Google Groups "Akka 
User List" group.
To unsubscribe from this group and stop receiving em