TopicOwnershipChangeListener tocl = (TopicOwnershipChangeListener) persistenceManager;
latch.acquire();
tocl.acquiredTopic(topic, new Callback<Void>() {
@Override
public void operationFailed(Object ctx, PubSubException exception) {
failureException = new RuntimeException(exception);
((Semaphore) ctx).release();
}