more robust subscription propagation using non blocking sockets