add types
add queue for detect fails in a message
create a queue process for each connection