Moved the opening of stream to the CreateSubscription method to make it ...

...work when we re-create a subscription