Connect to amqp within StreamingSubscription with localhost fallback