Refactored to use the OnMessageAsync pump. Seems reliable now. And fast :)
Tidied up queue/topic/subscription creation a little.
Removed unused variable.
Tweaked max concurrent requests to number of processors for now.