Incoming bytes are now analyzed by TcpConnectionHandler and correctly completed message body is published on broadcaster.
Then it is picked up by MessageListener (each is child of TcpConnectionHandler, thanks to this we have correct akka parent-child tree and each MessageListener is dedicated to exactly one socket connection).