In order to make this work like the rest of the scaleout providers do the following:

```C#
        private void SubscribeWithRetry(int topicCount)
        {
            while (true)
            {
                try
                {
                    _subscription = _connection.Subscribe(_topics, OnMessage, OnError);

                    _connection.ProcessReceivers(OnMessage, OnError);

                    // Open the streams after creating the subscription
                    for (int i = 0; i < topicCount; i++)
                    {
                        Open(i);
                    }

                    break;
                }
                catch (Exception ex)
                {
                    _trace.TraceError("Error Subscribe to ServiceBus - " + ex.GetBaseException());

                    Thread.Sleep(_retryDelay);
                }
            }
        }
```