writing new queue transport based on sockets