Moved the opening of stream to the CreateSubscription method to make it work when we re-create a subscription