Skip to content

Instantly share code, notes, and snippets.

@coreyauger
Created February 3, 2016 21:59
Show Gist options
  • Save coreyauger/0ce0b743c4e987218238 to your computer and use it in GitHub Desktop.
Save coreyauger/0ce0b743c4e987218238 to your computer and use it in GitHub Desktop.
[DEBUG] [02/03/2016 13:56:26.456] [core-akka.actor.default-dispatcher-28] [akka.tcp://core@127.0.0.1:44691/user/$z/stream0] stream=stream0 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:26.456] [core-akka.actor.default-dispatcher-28] [akka.tcp://core@127.0.0.1:44691/user/$z/stream0] stream=stream0 at=transition from=Empty to=Processing
[INFO] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-16] [akka.tcp://core@127.0.0.1:44691/user/$l] at=drain-finished
[INFO] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-16] [akka.tcp://core@127.0.0.1:44691/user/$l] at=committed-offsets
[INFO] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-16] [akka.tcp://core@127.0.0.1:44691/user/$l] at=transition from=Committing to=Receiving
[DEBUG] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-22] [akka.tcp://core@127.0.0.1:44691/user/$j] state=Committing msg=Drained(stream0) drained=1
[DEBUG] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-16] [akka.tcp://core@127.0.0.1:44691/user/$l] state=Receiving msg=Committed uncommitted=0
[DEBUG] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-23] [akka.tcp://core@127.0.0.1:44691/user/$H] state=Committing msg=Drained(stream0) drained=1
[DEBUG] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-16] [akka.tcp://core@127.0.0.1:44691/user/$l/stream0] stream=stream0 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-22] [akka.tcp://core@127.0.0.1:44691/user/$j] state=Committing msg=Drained(stream1) drained=2
[DEBUG] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-16] [akka.tcp://core@127.0.0.1:44691/user/$l/stream0] stream=stream0 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-23] [akka.tcp://core@127.0.0.1:44691/user/$H] state=Committing msg=Drained(stream1) drained=2
[DEBUG] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-22] [akka.tcp://core@127.0.0.1:44691/user/$j] state=Committing msg=Drained(stream3) drained=3
[INFO] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-15] [akka.tcp://core@127.0.0.1:44691/user/$f] at=transition from=Receiving to=Committing uncommitted=0
[DEBUG] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-22] [akka.tcp://core@127.0.0.1:44691/user/$j] state=Committing msg=Drained(stream2) drained=4
[INFO] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-22] [akka.tcp://core@127.0.0.1:44691/user/$j] at=drain-finished
[INFO] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-22] [akka.tcp://core@127.0.0.1:44691/user/$j] at=committed-offsets
[DEBUG] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-23] [akka.tcp://core@127.0.0.1:44691/user/$H] state=Committing msg=Drained(stream2) drained=3
[INFO] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-22] [akka.tcp://core@127.0.0.1:44691/user/$j] at=transition from=Committing to=Receiving
[DEBUG] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-22] [akka.tcp://core@127.0.0.1:44691/user/$z/stream1] stream=stream1 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-15] [akka.tcp://core@127.0.0.1:44691/user/$l/stream1] stream=stream1 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-22] [akka.tcp://core@127.0.0.1:44691/user/$z/stream1] stream=stream1 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-23] [akka.tcp://core@127.0.0.1:44691/user/$H] state=Committing msg=Drained(stream3) drained=4
[INFO] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-23] [akka.tcp://core@127.0.0.1:44691/user/$H] at=drain-finished
[DEBUG] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-15] [akka.tcp://core@127.0.0.1:44691/user/$l/stream1] stream=stream1 at=transition from=Empty to=Processing
[INFO] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-23] [akka.tcp://core@127.0.0.1:44691/user/$H] at=committed-offsets
[INFO] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-23] [akka.tcp://core@127.0.0.1:44691/user/$H] at=transition from=Committing to=Receiving
[DEBUG] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-17] [akka.tcp://core@127.0.0.1:44691/user/$p/stream1] stream=stream1 at=Drained
[DEBUG] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-17] [akka.tcp://core@127.0.0.1:44691/user/$p/stream1] stream=stream1 at=transition from=Unused to=Empty
[DEBUG] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-23] [akka.tcp://core@127.0.0.1:44691/user/$l/stream2] stream=stream2 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-23] [akka.tcp://core@127.0.0.1:44691/user/$l/stream2] stream=stream2 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-17] [akka.tcp://core@127.0.0.1:44691/user/$p] state=Committing msg=Drained(stream1) drained=4
[INFO] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-17] [akka.tcp://core@127.0.0.1:44691/user/$p] at=drain-finished
[INFO] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-17] [akka.tcp://core@127.0.0.1:44691/user/$p] at=committed-offsets
[INFO] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-17] [akka.tcp://core@127.0.0.1:44691/user/$p] at=transition from=Committing to=Receiving
[DEBUG] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-17] [akka.tcp://core@127.0.0.1:44691/user/$p] state=Receiving msg=Committed uncommitted=0
[DEBUG] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-17] [akka.tcp://core@127.0.0.1:44691/user/$l/stream3] stream=stream3 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-32] [akka.tcp://core@127.0.0.1:44691/user/$z/stream2] stream=stream2 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-17] [akka.tcp://core@127.0.0.1:44691/user/$l/stream3] stream=stream3 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:26.457] [core-akka.actor.default-dispatcher-32] [akka.tcp://core@127.0.0.1:44691/user/$z/stream2] stream=stream2 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:27.250] [core-akka.actor.default-dispatcher-27] [akka.tcp://core@127.0.0.1:44691/user/$B/stream3] stream=stream3 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:27.250] [core-akka.actor.default-dispatcher-30] [akka.tcp://core@127.0.0.1:44691/user/$B/stream1] stream=stream1 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:27.250] [core-akka.actor.default-dispatcher-25] [akka.tcp://core@127.0.0.1:44691/user/$B/stream0] stream=stream0 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:27.250] [core-akka.actor.default-dispatcher-19] [akka.tcp://core@127.0.0.1:44691/user/$B/stream2] stream=stream2 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:27.251] [core-akka.actor.default-dispatcher-27] [akka.tcp://core@127.0.0.1:44691/user/$B/stream3] stream=stream3 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:27.251] [core-akka.actor.default-dispatcher-25] [akka.tcp://core@127.0.0.1:44691/user/$B/stream0] stream=stream0 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:27.251] [core-akka.actor.default-dispatcher-30] [akka.tcp://core@127.0.0.1:44691/user/$B/stream1] stream=stream1 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:27.251] [core-akka.actor.default-dispatcher-19] [akka.tcp://core@127.0.0.1:44691/user/$B/stream2] stream=stream2 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:27.251] [core-akka.actor.default-dispatcher-25] [akka.tcp://core@127.0.0.1:44691/user/$p/stream1] stream=stream1 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.251] [core-akka.actor.default-dispatcher-30] [akka.tcp://core@127.0.0.1:44691/user/$f/stream0] stream=stream0 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.251] [core-akka.actor.default-dispatcher-27] [akka.tcp://core@127.0.0.1:44691/user/$p/stream0] stream=stream0 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.251] [core-akka.actor.default-dispatcher-19] [akka.tcp://core@127.0.0.1:44691/user/$p/stream2] stream=stream2 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.251] [core-akka.actor.default-dispatcher-25] [akka.tcp://core@127.0.0.1:44691/user/$p/stream1] stream=stream1 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:27.251] [core-akka.actor.default-dispatcher-30] [akka.tcp://core@127.0.0.1:44691/user/$f/stream0] stream=stream0 at=Drained
[DEBUG] [02/03/2016 13:56:27.251] [core-akka.actor.default-dispatcher-19] [akka.tcp://core@127.0.0.1:44691/user/$p/stream2] stream=stream2 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:27.251] [core-akka.actor.default-dispatcher-30] [akka.tcp://core@127.0.0.1:44691/user/$f/stream0] stream=stream0 at=transition from=Unused to=Empty
[DEBUG] [02/03/2016 13:56:27.251] [core-akka.actor.default-dispatcher-27] [akka.tcp://core@127.0.0.1:44691/user/$p/stream0] stream=stream0 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:27.252] [core-akka.actor.default-dispatcher-30] [akka.tcp://core@127.0.0.1:44691/user/$p/stream3] stream=stream3 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.252] [core-akka.actor.default-dispatcher-30] [akka.tcp://core@127.0.0.1:44691/user/$p/stream3] stream=stream3 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:27.255] [core-akka.actor.default-dispatcher-34] [akka.tcp://core@127.0.0.1:44691/user/$x/stream0] stream=stream0 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:27.255] [core-akka.actor.default-dispatcher-2] [akka.tcp://core@127.0.0.1:44691/user/$d/stream0] stream=stream0 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:27.255] [core-akka.actor.default-dispatcher-34] [akka.tcp://core@127.0.0.1:44691/user/$x/stream0] stream=stream0 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:27.255] [core-akka.actor.default-dispatcher-31] [akka.tcp://core@127.0.0.1:44691/user/$d/stream1] stream=stream1 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:27.255] [core-akka.actor.default-dispatcher-2] [akka.tcp://core@127.0.0.1:44691/user/$d/stream0] stream=stream0 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:27.255] [core-akka.actor.default-dispatcher-31] [akka.tcp://core@127.0.0.1:44691/user/$d/stream1] stream=stream1 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:27.255] [core-akka.actor.default-dispatcher-20] [akka.tcp://core@127.0.0.1:44691/user/$d/stream2] stream=stream2 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:27.255] [core-akka.actor.default-dispatcher-34] [akka.tcp://core@127.0.0.1:44691/user/$j/stream0] stream=stream0 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.255] [core-akka.actor.default-dispatcher-20] [akka.tcp://core@127.0.0.1:44691/user/$d/stream2] stream=stream2 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:27.255] [core-akka.actor.default-dispatcher-31] [akka.tcp://core@127.0.0.1:44691/user/$z/stream3] stream=stream3 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.255] [core-akka.actor.default-dispatcher-34] [akka.tcp://core@127.0.0.1:44691/user/$j/stream0] stream=stream0 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:27.255] [core-akka.actor.default-dispatcher-31] [akka.tcp://core@127.0.0.1:44691/user/$z/stream3] stream=stream3 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:27.255] [core-akka.actor.default-dispatcher-24] [akka.tcp://core@127.0.0.1:44691/user/$h/stream1] stream=stream1 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:27.255] [core-akka.actor.default-dispatcher-20] [akka.tcp://core@127.0.0.1:44691/user/$H/stream0] stream=stream0 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.255] [core-akka.actor.default-dispatcher-3] [akka.tcp://core@127.0.0.1:44691/user/$h/stream2] stream=stream2 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-24] [akka.tcp://core@127.0.0.1:44691/user/$h/stream1] stream=stream1 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-20] [akka.tcp://core@127.0.0.1:44691/user/$H/stream0] stream=stream0 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-4] [akka.tcp://core@127.0.0.1:44691/user/$d/stream3] stream=stream3 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-21] [akka.tcp://core@127.0.0.1:44691/user/$x/stream2] stream=stream2 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-24] [akka.tcp://core@127.0.0.1:44691/user/$t] state=Receiving msg=Commit uncommitted=0
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-4] [akka.tcp://core@127.0.0.1:44691/user/$d/stream3] stream=stream3 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-21] [akka.tcp://core@127.0.0.1:44691/user/$x/stream2] stream=stream2 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-3] [akka.tcp://core@127.0.0.1:44691/user/$h/stream2] stream=stream2 at=transition from=Processing to=Unused
[INFO] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-24] [akka.tcp://core@127.0.0.1:44691/user/$t] at=transition from=Receiving to=Committing uncommitted=0
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-26] [akka.tcp://core@127.0.0.1:44691/user/$x/stream1] stream=stream1 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-4] [akka.tcp://core@127.0.0.1:44691/user/$f/stream1] stream=stream1 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-21] [akka.tcp://core@127.0.0.1:44691/user/$H/stream1] stream=stream1 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-3] [akka.tcp://core@127.0.0.1:44691/user/$H/stream2] stream=stream2 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-2] [akka.tcp://core@127.0.0.1:44691/user/$f] state=Committing msg=Drained(stream0) drained=1
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-26] [akka.tcp://core@127.0.0.1:44691/user/$x/stream1] stream=stream1 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-4] [akka.tcp://core@127.0.0.1:44691/user/$f/stream1] stream=stream1 at=Drained
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-21] [akka.tcp://core@127.0.0.1:44691/user/$H/stream1] stream=stream1 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-4] [akka.tcp://core@127.0.0.1:44691/user/$f/stream1] stream=stream1 at=transition from=Unused to=Empty
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-3] [akka.tcp://core@127.0.0.1:44691/user/$H/stream2] stream=stream2 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-26] [akka.tcp://core@127.0.0.1:44691/user/$t/stream0] stream=stream0 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-4] [akka.tcp://core@127.0.0.1:44691/user/$t/stream1] stream=stream1 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-26] [akka.tcp://core@127.0.0.1:44691/user/$t/stream0] stream=stream0 at=Drained
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-4] [akka.tcp://core@127.0.0.1:44691/user/$t/stream1] stream=stream1 at=Drained
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-29] [akka.tcp://core@127.0.0.1:44691/user/$x/stream3] stream=stream3 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-24] [akka.tcp://core@127.0.0.1:44691/user/$t/stream2] stream=stream2 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-26] [akka.tcp://core@127.0.0.1:44691/user/$t/stream0] stream=stream0 at=transition from=Unused to=Empty
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-4] [akka.tcp://core@127.0.0.1:44691/user/$t/stream1] stream=stream1 at=transition from=Unused to=Empty
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-29] [akka.tcp://core@127.0.0.1:44691/user/$x/stream3] stream=stream3 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-24] [akka.tcp://core@127.0.0.1:44691/user/$t/stream2] stream=stream2 at=Drained
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-26] [akka.tcp://core@127.0.0.1:44691/user/$H/stream3] stream=stream3 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-24] [akka.tcp://core@127.0.0.1:44691/user/$t/stream2] stream=stream2 at=transition from=Unused to=Empty
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-2] [akka.tcp://core@127.0.0.1:44691/user/$f] state=Committing msg=Drained(stream1) drained=2
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-4] [akka.tcp://core@127.0.0.1:44691/user/$H] state=Receiving msg=Committed uncommitted=0
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-29] [akka.tcp://core@127.0.0.1:44691/user/$D] state=Receiving msg=Commit uncommitted=0
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-24] [akka.tcp://core@127.0.0.1:44691/user/$f/stream2] stream=stream2 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-26] [akka.tcp://core@127.0.0.1:44691/user/$H/stream3] stream=stream3 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-24] [akka.tcp://core@127.0.0.1:44691/user/$f/stream2] stream=stream2 at=Drained
[INFO] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-29] [akka.tcp://core@127.0.0.1:44691/user/$D] at=transition from=Receiving to=Committing uncommitted=0
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-4] [akka.tcp://core@127.0.0.1:44691/user/$t/stream3] stream=stream3 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-24] [akka.tcp://core@127.0.0.1:44691/user/$f/stream2] stream=stream2 at=transition from=Unused to=Empty
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-4] [akka.tcp://core@127.0.0.1:44691/user/$t/stream3] stream=stream3 at=Drained
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-24] [akka.tcp://core@127.0.0.1:44691/user/$f/stream3] stream=stream3 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-18] [akka.tcp://core@127.0.0.1:44691/user/$h/stream0] stream=stream0 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-4] [akka.tcp://core@127.0.0.1:44691/user/$t/stream3] stream=stream3 at=transition from=Unused to=Empty
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-24] [akka.tcp://core@127.0.0.1:44691/user/$f/stream3] stream=stream3 at=Drained
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-24] [akka.tcp://core@127.0.0.1:44691/user/$f/stream3] stream=stream3 at=transition from=Unused to=Empty
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-2] [akka.tcp://core@127.0.0.1:44691/user/$f] state=Committing msg=Drained(stream2) drained=3
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-18] [akka.tcp://core@127.0.0.1:44691/user/$h/stream0] stream=stream0 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-4] [akka.tcp://core@127.0.0.1:44691/user/$v] state=Receiving msg=Commit uncommitted=0
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-29] [akka.tcp://core@127.0.0.1:44691/user/$D/stream0] stream=stream0 state=Unused msg=Drain outstanding=0
[INFO] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-4] [akka.tcp://core@127.0.0.1:44691/user/$v] at=transition from=Receiving to=Committing uncommitted=0
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-29] [akka.tcp://core@127.0.0.1:44691/user/$D/stream0] stream=stream0 at=Drained
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-24] [akka.tcp://core@127.0.0.1:44691/user/$D/stream1] stream=stream1 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-29] [akka.tcp://core@127.0.0.1:44691/user/$D/stream0] stream=stream0 at=transition from=Unused to=Empty
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-18] [akka.tcp://core@127.0.0.1:44691/user/$D/stream2] stream=stream2 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.256] [core-akka.actor.default-dispatcher-24] [akka.tcp://core@127.0.0.1:44691/user/$D/stream1] stream=stream1 at=Drained
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-24] [akka.tcp://core@127.0.0.1:44691/user/$D/stream1] stream=stream1 at=transition from=Unused to=Empty
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-18] [akka.tcp://core@127.0.0.1:44691/user/$D/stream2] stream=stream2 at=Drained
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-24] [akka.tcp://core@127.0.0.1:44691/user/$D/stream3] stream=stream3 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-29] [akka.tcp://core@127.0.0.1:44691/user/$v/stream0] stream=stream0 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-18] [akka.tcp://core@127.0.0.1:44691/user/$D/stream2] stream=stream2 at=transition from=Unused to=Empty
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-24] [akka.tcp://core@127.0.0.1:44691/user/$D/stream3] stream=stream3 at=Drained
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-29] [akka.tcp://core@127.0.0.1:44691/user/$v/stream0] stream=stream0 at=Drained
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-18] [akka.tcp://core@127.0.0.1:44691/user/$v/stream1] stream=stream1 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-24] [akka.tcp://core@127.0.0.1:44691/user/$D/stream3] stream=stream3 at=transition from=Unused to=Empty
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-14] [akka.tcp://core@127.0.0.1:44691/user/$F/stream0] stream=stream0 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-29] [akka.tcp://core@127.0.0.1:44691/user/$v/stream0] stream=stream0 at=transition from=Unused to=Empty
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-2] [akka.tcp://core@127.0.0.1:44691/user/$f] state=Committing msg=Drained(stream3) drained=4
[INFO] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-2] [akka.tcp://core@127.0.0.1:44691/user/$f] at=drain-finished
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-18] [akka.tcp://core@127.0.0.1:44691/user/$v/stream1] stream=stream1 at=Drained
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-14] [akka.tcp://core@127.0.0.1:44691/user/$F/stream0] stream=stream0 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-4] [akka.tcp://core@127.0.0.1:44691/user/$D] state=Committing msg=Drained(stream0) drained=1
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-18] [akka.tcp://core@127.0.0.1:44691/user/$v/stream1] stream=stream1 at=transition from=Unused to=Empty
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-14] [akka.tcp://core@127.0.0.1:44691/user/$v/stream3] stream=stream3 state=Unused msg=Drain outstanding=0
[INFO] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-2] [akka.tcp://core@127.0.0.1:44691/user/$f] at=committed-offsets
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-29] [akka.tcp://core@127.0.0.1:44691/user/$v/stream2] stream=stream2 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-18] [akka.tcp://core@127.0.0.1:44691/user/$F/stream1] stream=stream1 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-24] [akka.tcp://core@127.0.0.1:44691/user/$v] state=Committing msg=Drained(stream0) drained=1
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-14] [akka.tcp://core@127.0.0.1:44691/user/$v/stream3] stream=stream3 at=Drained
[INFO] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-2] [akka.tcp://core@127.0.0.1:44691/user/$f] at=transition from=Committing to=Receiving
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-14] [akka.tcp://core@127.0.0.1:44691/user/$v/stream3] stream=stream3 at=transition from=Unused to=Empty
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-29] [akka.tcp://core@127.0.0.1:44691/user/$v/stream2] stream=stream2 at=Drained
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-18] [akka.tcp://core@127.0.0.1:44691/user/$F/stream1] stream=stream1 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-29] [akka.tcp://core@127.0.0.1:44691/user/$v/stream2] stream=stream2 at=transition from=Unused to=Empty
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-4] [akka.tcp://core@127.0.0.1:44691/user/$D] state=Committing msg=Drained(stream1) drained=2
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-24] [akka.tcp://core@127.0.0.1:44691/user/$v] state=Committing msg=Drained(stream1) drained=2
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-2] [akka.tcp://core@127.0.0.1:44691/user/$f] state=Receiving msg=Committed uncommitted=0
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-2] [akka.tcp://core@127.0.0.1:44691/user/$f/stream0] stream=stream0 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-4] [akka.tcp://core@127.0.0.1:44691/user/$D] state=Committing msg=Drained(stream2) drained=3
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-2] [akka.tcp://core@127.0.0.1:44691/user/$f/stream0] stream=stream0 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-24] [akka.tcp://core@127.0.0.1:44691/user/$v] state=Committing msg=Drained(stream3) drained=3
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-4] [akka.tcp://core@127.0.0.1:44691/user/$D] state=Committing msg=Drained(stream3) drained=4
[INFO] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-4] [akka.tcp://core@127.0.0.1:44691/user/$D] at=drain-finished
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-28] [akka.tcp://core@127.0.0.1:44691/user/$z/stream0] stream=stream0 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-28] [akka.tcp://core@127.0.0.1:44691/user/$z/stream0] stream=stream0 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-24] [akka.tcp://core@127.0.0.1:44691/user/$v] state=Committing msg=Drained(stream2) drained=4
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-33] [akka.tcp://core@127.0.0.1:44691/user/$h/stream3] stream=stream3 state=Processing msg=Continue outstanding=0
[INFO] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-24] [akka.tcp://core@127.0.0.1:44691/user/$v] at=drain-finished
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-28] [akka.tcp://core@127.0.0.1:44691/user/$j/stream1] stream=stream1 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-33] [akka.tcp://core@127.0.0.1:44691/user/$h/stream3] stream=stream3 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-28] [akka.tcp://core@127.0.0.1:44691/user/$j/stream1] stream=stream1 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-14] [akka.tcp://core@127.0.0.1:44691/system/cluster/core/daemon/heartbeatSender] Cluster Node [akka.tcp://core@127.0.0.1:44691] - Heartbeat to [akka.tcp://core@127.0.0.1:37759]
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-16] [akka.tcp://core@127.0.0.1:44691/user/$l/stream0] stream=stream0 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:27.257] [core-akka.actor.default-dispatcher-16] [akka.tcp://core@127.0.0.1:44691/user/$l/stream0] stream=stream0 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-32] [akka.tcp://core@127.0.0.1:44691/user/$z/stream2] stream=stream2 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-17] [akka.tcp://core@127.0.0.1:44691/user/$l/stream3] stream=stream3 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-32] [akka.tcp://core@127.0.0.1:44691/user/$z/stream2] stream=stream2 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-23] [akka.tcp://core@127.0.0.1:44691/user/$l/stream2] stream=stream2 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-17] [akka.tcp://core@127.0.0.1:44691/user/$l/stream3] stream=stream3 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-32] [akka.tcp://core@127.0.0.1:44691/user/$j/stream2] stream=stream2 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-23] [akka.tcp://core@127.0.0.1:44691/user/$l/stream2] stream=stream2 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-17] [akka.tcp://core@127.0.0.1:44691/user/$j/stream3] stream=stream3 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-32] [akka.tcp://core@127.0.0.1:44691/user/$j/stream2] stream=stream2 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-23] [akka.tcp://core@127.0.0.1:44691/user/$f/stream1] stream=stream1 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-17] [akka.tcp://core@127.0.0.1:44691/user/$j/stream3] stream=stream3 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-23] [akka.tcp://core@127.0.0.1:44691/user/$f/stream1] stream=stream1 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-14] [akka.tcp://core@127.0.0.1:44691/system/cluster/core/daemon/heartbeatSender] Cluster Node [akka.tcp://core@127.0.0.1:44691] - Heartbeat to [akka.tcp://core@127.0.0.1:58166]
[DEBUG] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-15] [akka.tcp://core@127.0.0.1:44691/user/$l/stream1] stream=stream1 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-22] [akka.tcp://core@127.0.0.1:44691/user/$z/stream1] stream=stream1 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-15] [akka.tcp://core@127.0.0.1:44691/user/$l/stream1] stream=stream1 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-22] [akka.tcp://core@127.0.0.1:44691/user/$z/stream1] stream=stream1 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-14] [akka.tcp://core@127.0.0.1:44691/system/cluster/core/daemon/heartbeatSender] Cluster Node [akka.tcp://core@127.0.0.1:44691] - Heartbeat to [akka.tcp://core@127.0.0.1:39481]
[DEBUG] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-15] [akka.tcp://core@127.0.0.1:44691/user/$j] state=Receiving msg=Committed uncommitted=0
[DEBUG] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-22] [akka.tcp://core@127.0.0.1:44691/user/$f/stream2] stream=stream2 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-15] [akka.tcp://core@127.0.0.1:44691/user/$F/stream2] stream=stream2 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-14] [akka.tcp://core@127.0.0.1:44691/system/cluster/core/daemon/heartbeatSender] Cluster Node [akka.tcp://core@127.0.0.1:44691] - Heartbeat to [akka.tcp://core@127.0.0.1:2551]
[DEBUG] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-15] [akka.tcp://core@127.0.0.1:44691/user/$F/stream2] stream=stream2 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-22] [akka.tcp://core@127.0.0.1:44691/user/$f/stream2] stream=stream2 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-14] [akka.tcp://core@127.0.0.1:44691/user/$F/stream3] stream=stream3 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-14] [akka.tcp://core@127.0.0.1:44691/user/$F/stream3] stream=stream3 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-33] [akka.tcp://core@127.0.0.1:44691/user/$r] state=Committing msg=Drained(stream1) drained=2
[DEBUG] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-33] [akka.tcp://core@127.0.0.1:44691/user/$r] state=Committing msg=Drained(stream2) drained=3
[DEBUG] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-33] [akka.tcp://core@127.0.0.1:44691/user/$r] state=Committing msg=Drained(stream3) drained=4
[INFO] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-33] [akka.tcp://core@127.0.0.1:44691/user/$r] at=drain-finished
[INFO] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-33] [akka.tcp://core@127.0.0.1:44691/user/$r] at=committed-offsets
[INFO] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-33] [akka.tcp://core@127.0.0.1:44691/user/$r] at=transition from=Committing to=Receiving
[DEBUG] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-33] [akka.tcp://core@127.0.0.1:44691/user/$r] state=Receiving msg=Committed uncommitted=0
[DEBUG] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-33] [akka.tcp://core@127.0.0.1:44691/user/$n/stream0] stream=stream0 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.258] [core-akka.actor.default-dispatcher-33] [akka.tcp://core@127.0.0.1:44691/user/$n/stream0] stream=stream0 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:27.259] [core-akka.actor.default-dispatcher-16] [akka.tcp://core@127.0.0.1:44691/user/$f/stream3] stream=stream3 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.259] [core-akka.actor.default-dispatcher-16] [akka.tcp://core@127.0.0.1:44691/user/$f/stream3] stream=stream3 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:27.259] [core-akka.actor.default-dispatcher-29] [akka.tcp://core@127.0.0.1:44691/user/$r/stream0] stream=stream0 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.259] [core-akka.actor.default-dispatcher-29] [akka.tcp://core@127.0.0.1:44691/user/$r/stream0] stream=stream0 at=transition from=Empty to=Processing
[INFO] [02/03/2016 13:56:27.552] [core-akka.actor.default-dispatcher-4] [akka.tcp://core@127.0.0.1:44691/user/$D] at=committed-offsets
[INFO] [02/03/2016 13:56:27.553] [core-akka.actor.default-dispatcher-4] [akka.tcp://core@127.0.0.1:44691/user/$D] at=transition from=Committing to=Receiving
[DEBUG] [02/03/2016 13:56:27.553] [core-akka.actor.default-dispatcher-4] [akka.tcp://core@127.0.0.1:44691/user/$D] state=Receiving msg=Committed uncommitted=0
[DEBUG] [02/03/2016 13:56:27.553] [core-akka.actor.default-dispatcher-4] [akka.tcp://core@127.0.0.1:44691/user/$r/stream1] stream=stream1 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.553] [core-akka.actor.default-dispatcher-4] [akka.tcp://core@127.0.0.1:44691/user/$r/stream1] stream=stream1 at=transition from=Empty to=Processing
[INFO] [02/03/2016 13:56:27.563] [core-akka.actor.default-dispatcher-24] [akka.tcp://core@127.0.0.1:44691/user/$v] at=committed-offsets
[INFO] [02/03/2016 13:56:27.563] [core-akka.actor.default-dispatcher-24] [akka.tcp://core@127.0.0.1:44691/user/$v] at=transition from=Committing to=Receiving
[DEBUG] [02/03/2016 13:56:27.564] [core-akka.actor.default-dispatcher-24] [akka.tcp://core@127.0.0.1:44691/user/$v] state=Receiving msg=Committed uncommitted=0
[DEBUG] [02/03/2016 13:56:27.564] [core-akka.actor.default-dispatcher-24] [akka.tcp://core@127.0.0.1:44691/user/$n/stream1] stream=stream1 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:27.564] [core-akka.actor.default-dispatcher-24] [akka.tcp://core@127.0.0.1:44691/user/$n/stream1] stream=stream1 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:28.052] [core-akka.actor.default-dispatcher-25] [akka.tcp://core@127.0.0.1:44691/user/$p/stream1] stream=stream1 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:28.052] [core-akka.actor.default-dispatcher-19] [akka.tcp://core@127.0.0.1:44691/user/$p/stream2] stream=stream2 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:28.052] [core-akka.actor.default-dispatcher-25] [akka.tcp://core@127.0.0.1:44691/user/$p/stream1] stream=stream1 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:28.052] [core-akka.actor.default-dispatcher-19] [akka.tcp://core@127.0.0.1:44691/user/$p/stream2] stream=stream2 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:28.052] [core-akka.actor.default-dispatcher-27] [akka.tcp://core@127.0.0.1:44691/user/$p/stream0] stream=stream0 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:28.052] [core-akka.actor.default-dispatcher-27] [akka.tcp://core@127.0.0.1:44691/user/$p/stream0] stream=stream0 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:28.052] [core-akka.actor.default-dispatcher-25] [akka.tcp://core@127.0.0.1:44691/user/$D/stream0] stream=stream0 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:28.052] [core-akka.actor.default-dispatcher-19] [akka.tcp://core@127.0.0.1:44691/system/cluster/core/daemon/heartbeatSender] Cluster Node [akka.tcp://core@127.0.0.1:44691] - Heartbeat response from [akka.tcp://core@127.0.0.1:2551]
[DEBUG] [02/03/2016 13:56:28.052] [core-akka.actor.default-dispatcher-25] [akka.tcp://core@127.0.0.1:44691/user/$D/stream0] stream=stream0 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:28.052] [core-akka.actor.default-dispatcher-19] [akka.tcp://core@127.0.0.1:44691/system/cluster/core/daemon/heartbeatSender] Cluster Node [akka.tcp://core@127.0.0.1:44691] - Heartbeat response from [akka.tcp://core@127.0.0.1:37759]
[DEBUG] [02/03/2016 13:56:28.052] [core-akka.actor.default-dispatcher-27] [akka.tcp://core@127.0.0.1:44691/user/$r/stream2] stream=stream2 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:28.052] [core-akka.actor.default-dispatcher-19] [akka.tcp://core@127.0.0.1:44691/system/cluster/core/daemon/heartbeatSender] Cluster Node [akka.tcp://core@127.0.0.1:44691] - Heartbeat response from [akka.tcp://core@127.0.0.1:58166]
[DEBUG] [02/03/2016 13:56:28.052] [core-akka.actor.default-dispatcher-27] [akka.tcp://core@127.0.0.1:44691/user/$r/stream2] stream=stream2 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:28.052] [core-akka.actor.default-dispatcher-19] [akka.tcp://core@127.0.0.1:44691/system/cluster/core/daemon/heartbeatSender] Cluster Node [akka.tcp://core@127.0.0.1:44691] - Heartbeat response from [akka.tcp://core@127.0.0.1:39481]
[DEBUG] [02/03/2016 13:56:28.052] [core-akka.actor.default-dispatcher-19] [akka.tcp://core@127.0.0.1:44691/user/$D/stream1] stream=stream1 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:28.052] [core-akka.actor.default-dispatcher-19] [akka.tcp://core@127.0.0.1:44691/user/$D/stream1] stream=stream1 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:28.052] [core-akka.actor.default-dispatcher-30] [akka.tcp://core@127.0.0.1:44691/user/$p/stream3] stream=stream3 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:28.052] [core-akka.actor.default-dispatcher-30] [akka.tcp://core@127.0.0.1:44691/user/$p/stream3] stream=stream3 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:28.052] [core-akka.actor.default-dispatcher-30] [akka.tcp://core@127.0.0.1:44691/user/$r/stream3] stream=stream3 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:28.052] [core-akka.actor.default-dispatcher-30] [akka.tcp://core@127.0.0.1:44691/user/$r/stream3] stream=stream3 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:28.056] [core-akka.actor.default-dispatcher-31] [akka.tcp://core@127.0.0.1:44691/user/$z/stream3] stream=stream3 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:28.056] [core-akka.actor.default-dispatcher-34] [akka.tcp://core@127.0.0.1:44691/user/$j/stream0] stream=stream0 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:28.056] [core-akka.actor.default-dispatcher-20] [akka.tcp://core@127.0.0.1:44691/user/$H/stream0] stream=stream0 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:28.056] [core-akka.actor.default-dispatcher-20] [akka.tcp://core@127.0.0.1:44691/user/$H/stream0] stream=stream0 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:28.056] [core-akka.actor.default-dispatcher-31] [akka.tcp://core@127.0.0.1:44691/user/$z/stream3] stream=stream3 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:28.056] [core-akka.actor.default-dispatcher-34] [akka.tcp://core@127.0.0.1:44691/user/$j/stream0] stream=stream0 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:28.056] [core-akka.actor.default-dispatcher-31] [akka.tcp://core@127.0.0.1:44691/user/$D/stream2] stream=stream2 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:28.056] [core-akka.actor.default-dispatcher-34] [akka.tcp://core@127.0.0.1:44691/user/$v/stream0] stream=stream0 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:28.056] [core-akka.actor.default-dispatcher-20] [akka.tcp://core@127.0.0.1:44691/user/$n/stream2] stream=stream2 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:28.056] [core-akka.actor.default-dispatcher-31] [akka.tcp://core@127.0.0.1:44691/user/$D/stream2] stream=stream2 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:28.056] [core-akka.actor.default-dispatcher-34] [akka.tcp://core@127.0.0.1:44691/user/$v/stream0] stream=stream0 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:28.056] [core-akka.actor.default-dispatcher-20] [akka.tcp://core@127.0.0.1:44691/user/$n/stream2] stream=stream2 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:28.056] [core-akka.actor.default-dispatcher-21] [akka.tcp://core@127.0.0.1:44691/user/$H/stream1] stream=stream1 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:28.056] [core-akka.actor.default-dispatcher-21] [akka.tcp://core@127.0.0.1:44691/user/$H/stream1] stream=stream1 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:28.056] [core-akka.actor.default-dispatcher-3] [akka.tcp://core@127.0.0.1:44691/user/$H/stream2] stream=stream2 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:28.056] [core-akka.actor.default-dispatcher-21] [akka.tcp://core@127.0.0.1:44691/user/$n/stream3] stream=stream3 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:28.057] [core-akka.actor.default-dispatcher-26] [akka.tcp://core@127.0.0.1:44691/user/$H/stream3] stream=stream3 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:28.057] [core-akka.actor.default-dispatcher-3] [akka.tcp://core@127.0.0.1:44691/user/$H/stream2] stream=stream2 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:28.058] [core-akka.actor.default-dispatcher-21] [akka.tcp://core@127.0.0.1:44691/user/$n/stream3] stream=stream3 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:28.059] [core-akka.actor.default-dispatcher-33] [akka.tcp://core@127.0.0.1:44691/user/$n/stream0] stream=stream0 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:28.059] [core-akka.actor.default-dispatcher-33] [akka.tcp://core@127.0.0.1:44691/user/$n/stream0] stream=stream0 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:28.059] [core-akka.actor.default-dispatcher-33] [akka.tcp://core@127.0.0.1:44691/user/$D/stream3] stream=stream3 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:28.059] [core-akka.actor.default-dispatcher-33] [akka.tcp://core@127.0.0.1:44691/user/$D/stream3] stream=stream3 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:28.059] [core-akka.actor.default-dispatcher-3] [akka.tcp://core@127.0.0.1:44691/user/$t] state=Committing msg=Drained(stream0) drained=1
[DEBUG] [02/03/2016 13:56:28.059] [core-akka.actor.default-dispatcher-3] [akka.tcp://core@127.0.0.1:44691/user/$t] state=Committing msg=Drained(stream1) drained=2
[DEBUG] [02/03/2016 13:56:28.059] [core-akka.actor.default-dispatcher-3] [akka.tcp://core@127.0.0.1:44691/user/$t] state=Committing msg=Drained(stream2) drained=3
[DEBUG] [02/03/2016 13:56:28.059] [core-akka.actor.default-dispatcher-16] [akka.tcp://core@127.0.0.1:44691/user/$f/stream3] stream=stream3 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:28.059] [core-akka.actor.default-dispatcher-16] [akka.tcp://core@127.0.0.1:44691/user/$f/stream3] stream=stream3 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:28.059] [core-akka.actor.default-dispatcher-3] [akka.tcp://core@127.0.0.1:44691/user/$t] state=Committing msg=Drained(stream3) drained=4
[INFO] [02/03/2016 13:56:28.059] [core-akka.actor.default-dispatcher-3] [akka.tcp://core@127.0.0.1:44691/user/$t] at=drain-finished
[DEBUG] [02/03/2016 13:56:28.060] [core-akka.actor.default-dispatcher-29] [akka.tcp://core@127.0.0.1:44691/user/$r/stream0] stream=stream0 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:28.060] [core-akka.actor.default-dispatcher-29] [akka.tcp://core@127.0.0.1:44691/user/$r/stream0] stream=stream0 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:28.060] [core-akka.actor.default-dispatcher-14] [akka.tcp://core@127.0.0.1:44691/user/$F/stream3] stream=stream3 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:28.060] [core-akka.actor.default-dispatcher-22] [akka.tcp://core@127.0.0.1:44691/user/$f/stream2] stream=stream2 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:28.060] [core-akka.actor.default-dispatcher-14] [akka.tcp://core@127.0.0.1:44691/user/$F/stream3] stream=stream3 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:28.060] [core-akka.actor.default-dispatcher-22] [akka.tcp://core@127.0.0.1:44691/user/$f/stream2] stream=stream2 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:28.060] [core-akka.actor.default-dispatcher-22] [akka.tcp://core@127.0.0.1:44691/user/$v/stream1] stream=stream1 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:28.060] [core-akka.actor.default-dispatcher-16] [akka.tcp://core@127.0.0.1:44691/user/$v/stream2] stream=stream2 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:28.060] [core-akka.actor.default-dispatcher-22] [akka.tcp://core@127.0.0.1:44691/user/$v/stream1] stream=stream1 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:28.060] [core-akka.actor.default-dispatcher-16] [akka.tcp://core@127.0.0.1:44691/user/$v/stream2] stream=stream2 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:28.060] [core-akka.actor.default-dispatcher-15] [akka.tcp://core@127.0.0.1:44691/user/$F/stream2] stream=stream2 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:28.060] [core-akka.actor.default-dispatcher-15] [akka.tcp://core@127.0.0.1:44691/user/$F/stream2] stream=stream2 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:28.060] [core-akka.actor.default-dispatcher-23] [akka.tcp://core@127.0.0.1:44691/user/$f/stream1] stream=stream1 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:28.060] [core-akka.actor.default-dispatcher-32] [akka.tcp://core@127.0.0.1:44691/user/$j/stream2] stream=stream2 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:28.060] [core-akka.actor.default-dispatcher-15] [akka.tcp://core@127.0.0.1:44691/user/$v/stream3] stream=stream3 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:28.060] [core-akka.actor.default-dispatcher-17] [akka.tcp://core@127.0.0.1:44691/user/$j/stream3] stream=stream3 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:28.060] [core-akka.actor.default-dispatcher-23] [akka.tcp://core@127.0.0.1:44691/user/$f/stream1] stream=stream1 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:28.060] [core-akka.actor.default-dispatcher-32] [akka.tcp://core@127.0.0.1:44691/user/$j/stream2] stream=stream2 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:28.060] [core-akka.actor.default-dispatcher-15] [akka.tcp://core@127.0.0.1:44691/user/$v/stream3] stream=stream3 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:28.060] [core-akka.actor.default-dispatcher-17] [akka.tcp://core@127.0.0.1:44691/user/$j/stream3] stream=stream3 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:28.060] [core-akka.actor.default-dispatcher-28] [akka.tcp://core@127.0.0.1:44691/user/$j/stream1] stream=stream1 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:28.060] [core-akka.actor.default-dispatcher-2] [akka.tcp://core@127.0.0.1:44691/user/$f/stream0] stream=stream0 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:28.060] [core-akka.actor.default-dispatcher-28] [akka.tcp://core@127.0.0.1:44691/user/$j/stream1] stream=stream1 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:28.060] [core-akka.actor.default-dispatcher-2] [akka.tcp://core@127.0.0.1:44691/user/$f/stream0] stream=stream0 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:28.060] [core-akka.actor.default-dispatcher-26] [akka.tcp://core@127.0.0.1:44691/user/$H/stream3] stream=stream3 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:28.060] [core-akka.actor.default-dispatcher-18] [akka.tcp://core@127.0.0.1:44691/user/$F/stream1] stream=stream1 state=Processing msg=Continue outstanding=0
[DEBUG] [02/03/2016 13:56:28.060] [core-akka.actor.default-dispatcher-18] [akka.tcp://core@127.0.0.1:44691/user/$F/stream1] stream=stream1 at=transition from=Processing to=Unused
[DEBUG] [02/03/2016 13:56:28.093] [core-akka.actor.default-dispatcher-29] [akka.tcp://core@127.0.0.1:44691/system/cluster/core/daemon/heartbeatSender] Cluster Node [akka.tcp://core@127.0.0.1:44691] - Heartbeat to [akka.tcp://core@127.0.0.1:37759]
[DEBUG] [02/03/2016 13:56:28.093] [core-akka.actor.default-dispatcher-29] [akka.tcp://core@127.0.0.1:44691/system/cluster/core/daemon/heartbeatSender] Cluster Node [akka.tcp://core@127.0.0.1:44691] - Heartbeat to [akka.tcp://core@127.0.0.1:58166]
[DEBUG] [02/03/2016 13:56:28.093] [core-akka.actor.default-dispatcher-29] [akka.tcp://core@127.0.0.1:44691/system/cluster/core/daemon/heartbeatSender] Cluster Node [akka.tcp://core@127.0.0.1:44691] - Heartbeat to [akka.tcp://core@127.0.0.1:39481]
[DEBUG] [02/03/2016 13:56:28.093] [core-akka.actor.default-dispatcher-29] [akka.tcp://core@127.0.0.1:44691/system/cluster/core/daemon/heartbeatSender] Cluster Node [akka.tcp://core@127.0.0.1:44691] - Heartbeat to [akka.tcp://core@127.0.0.1:2551]
[DEBUG] [02/03/2016 13:56:28.094] [core-akka.actor.default-dispatcher-26] [akka.tcp://core@127.0.0.1:44691/system/cluster/core/daemon/heartbeatSender] Cluster Node [akka.tcp://core@127.0.0.1:44691] - Heartbeat response from [akka.tcp://core@127.0.0.1:2551]
[DEBUG] [02/03/2016 13:56:28.095] [core-akka.actor.default-dispatcher-26] [akka.tcp://core@127.0.0.1:44691/system/cluster/core/daemon/heartbeatSender] Cluster Node [akka.tcp://core@127.0.0.1:44691] - Heartbeat response from [akka.tcp://core@127.0.0.1:39481]
[DEBUG] [02/03/2016 13:56:28.095] [core-akka.actor.default-dispatcher-26] [akka.tcp://core@127.0.0.1:44691/system/cluster/core/daemon/heartbeatSender] Cluster Node [akka.tcp://core@127.0.0.1:44691] - Heartbeat response from [akka.tcp://core@127.0.0.1:58166]
[DEBUG] [02/03/2016 13:56:28.095] [core-akka.actor.default-dispatcher-26] [akka.tcp://core@127.0.0.1:44691/system/cluster/core/daemon/heartbeatSender] Cluster Node [akka.tcp://core@127.0.0.1:44691] - Heartbeat response from [akka.tcp://core@127.0.0.1:37759]
NODE
{
"eventId" : "f8bd5f40-cac0-11e5-bceb-10feed2de017",
"eventType" : "m.Graph.GetProfileRelationships",
"source" : "akka.tcp://core@127.0.0.1:58166/user/$ob",
"userIdentifier" : [ "ba5c4a10-30cc-4c4c-a030-27f5595b76db" ],
"correlationId" : [ "ba5c4a10-30cc-4c4c-a030-27f5595b76db" ],
"occurredAt" : "2016-02-03 13:56:26",
"publishedAt" : "2016-02-03 13:56:26",
"payload" : {
"$type" : "m.Graph.GetProfileRelationships",
"provider" : [ "conversant" ],
"direction" : {
"direction" : "out"
},
"orgId" : [ "5322cd7f-ba1a-48e3-afdd-d63b66d12ca6" ],
"relationship" : {
"$type" : "m.Auth.OrganizationRoles",
"name" : "team"
},
"userId" : "5322cd7f-ba1a-48e3-afdd-d63b66d12ca6"
}
}
[INFO] [02/03/2016 13:56:28.118] [core-akka.actor.default-dispatcher-3] [akka.tcp://core@127.0.0.1:44691/user/$t] at=committed-offsets
[INFO] [02/03/2016 13:56:28.118] [core-akka.actor.default-dispatcher-3] [akka.tcp://core@127.0.0.1:44691/user/$t] at=transition from=Committing to=Receiving
[DEBUG] [02/03/2016 13:56:28.118] [core-akka.actor.default-dispatcher-26] [akka.tcp://core@127.0.0.1:44691/user/$t/stream0] stream=stream0 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:28.118] [core-akka.actor.default-dispatcher-3] [akka.tcp://core@127.0.0.1:44691/user/$t] state=Receiving msg=Committed uncommitted=0
[DEBUG] [02/03/2016 13:56:28.118] [core-akka.actor.default-dispatcher-28] [akka.tcp://core@127.0.0.1:44691/user/$t/stream1] stream=stream1 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:28.118] [core-akka.actor.default-dispatcher-26] [akka.tcp://core@127.0.0.1:44691/user/$t/stream0] stream=stream0 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:28.118] [core-akka.actor.default-dispatcher-3] [akka.tcp://core@127.0.0.1:44691/user/$t/stream2] stream=stream2 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:28.118] [core-akka.actor.default-dispatcher-28] [akka.tcp://core@127.0.0.1:44691/user/$t/stream1] stream=stream1 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:28.118] [core-akka.actor.default-dispatcher-3] [akka.tcp://core@127.0.0.1:44691/user/$t/stream2] stream=stream2 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:28.118] [core-akka.actor.default-dispatcher-14] [akka.tcp://core@127.0.0.1:44691/user/$t/stream3] stream=stream3 state=Unused msg=Drain outstanding=0
[DEBUG] [02/03/2016 13:56:28.118] [core-akka.actor.default-dispatcher-14] [akka.tcp://core@127.0.0.1:44691/user/$t/stream3] stream=stream3 at=transition from=Empty to=Processing
[DEBUG] [02/03/2016 13:56:28.240] [core-akka.actor.default-dispatcher-31] [akka.tcp://core@127.0.0.1:44691/user/$D/stream2] stream=stream2 state=Processing msg=Continue outstanding=1
[DEBUG] [02/03/2016 13:56:28.242] [core-akka.actor.default-dispatcher-29] [akka.tcp://core@127.0.0.1:44691/user/$D] state=Receiving msg=Received uncommitted=1
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment