Skip to content

Commit

Permalink
fix formatting violation
Browse files Browse the repository at this point in the history
  • Loading branch information
rdhabalia committed Oct 14, 2021
1 parent 8219cec commit 04a9891
Showing 1 changed file with 0 additions and 17 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -34,9 +34,6 @@
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Executor;
import java.util.concurrent.TimeUnit;

import org.apache.commons.lang3.mutable.MutableInt;
import org.apache.commons.lang3.mutable.MutableObject;
import org.apache.commons.lang3.tuple.ImmutablePair;
import org.apache.commons.lang3.tuple.Pair;
import org.apache.pulsar.broker.PulsarService;
Expand All @@ -50,7 +47,6 @@
import org.apache.pulsar.stats.CacheMetricsCollector;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.github.benmanes.caffeine.cache.AsyncLoadingCache;
import com.github.benmanes.caffeine.cache.Caffeine;
import com.google.common.base.Charsets;
Expand Down Expand Up @@ -170,19 +166,6 @@ private void handleMetadataStoreNotification(Notification n) {
}
}

/**
* checks if the local broker is the owner of the namespace bundle.
*
* @param nsBundle
* @return
*/
private boolean isOwner(NamespaceBundle nsBundle) {
if (pulsar != null) {
return pulsar.getNamespaceService().getOwnershipCache().getOwnedBundle(nsBundle) != null;
}
return false;
}

public void invalidateBundleCache(NamespaceName namespace) {
bundlesCache.synchronous().invalidate(namespace);
}
Expand Down

0 comments on commit 04a9891

Please sign in to comment.