Fixed concurrency issue and better handling of channel closing and recreation, one channel per queue