[BOOKKEEPER-532] AbstractSubscriptionManager#AcquireOp read subscriptions every time even it already owned the topic

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 4.2.0
• Component/s: hedwig-server
• Assignee: Sijie Guo
• Reporter: Sijie Guo
• Created: 05/Jan/13 08:12
• Updated: 13/Feb/13 15:46
• Resolved: 07/Jan/13 23:45

Description

    private class AcquireOp extends TopicOpQueuer.AsynchronousOp<Void> {
        public AcquireOp(ByteString topic, Callback<Void> callback, Object ctx) {
            queuer.super(topic, callback, ctx);
        }   

        @Override
        public void run() {
            if (top2sub2seq.containsKey(topic)) {
                cb.operationFinished(ctx, null);
            }   

            readSubscriptions(topic, new Callback<Map<ByteString, InMemorySubscriptionState>>() {

it doesn't return after it found subscriptions and callback.