Skip to content
Browse files

BOOKKEEPER-532: AbstractSubscriptionManager#AcquireOp read subscripti…

…ons every time even it already owned the topic. (sijie via fpj)

git-svn-id: 13f79535-47bb-0310-9956-ffa450edef68
  • Loading branch information...
1 parent f7ce39d commit ed9b6037be51845f7cab2446593df695ffcede59 @fpj fpj committed Jan 7, 2013
@@ -218,6 +218,8 @@ Trunk (unreleased changes)
BOOKKEEPER-507: Race condition happens if closeSubscription and subscribe happened at the same time (in multiplexed client). (sijie via ivank)
+ BOOKKEEPER-532: AbstractSubscriptionManager#AcquireOp read subscriptions every time even it already owned the topic. (sijie via fpj)
BOOKKEEPER-467: Allocate ports for testing dynamically (ivank)
1 ...ver/src/main/java/org/apache/hedwig/server/subscriptions/
@@ -165,6 +165,7 @@ public AcquireOp(ByteString topic, Callback<Void> callback, Object ctx) {
public void run() {
if (top2sub2seq.containsKey(topic)) {
cb.operationFinished(ctx, null);
+ return;
readSubscriptions(topic, new Callback<Map<ByteString, InMemorySubscriptionState>>() {

0 comments on commit ed9b603

Please sign in to comment.
Something went wrong with that request. Please try again.