Reimplement Azure pubsub provider using Service Bus Queues