Latest fixes to streaming via sockets using async messages over mq