// Release the started Latch since another thread could be
// stuck waiting for it to start up.
startedLatch.countDown();
startedLatch.countDown();
localStartedLatch.countDown();
ss.throwFirstException();
}
}
LOG.info(configuration.getBrokerName() + " bridge to " + remoteBrokerName + " stopped");
}
}