Check the sources of
phex.connection.ConnectionEngine - which handles each single connection.
and
phex.msg.MsgManager - which is doing message routing based on routing tables.

__________________