diff --git a/concurrency-limits-core/src/main/java/com/netflix/concurrency/limits/limiter/AbstractPartitionedLimiter.java b/concurrency-limits-core/src/main/java/com/netflix/concurrency/limits/limiter/AbstractPartitionedLimiter.java index 66764f3..a635752 100644 --- a/concurrency-limits-core/src/main/java/com/netflix/concurrency/limits/limiter/AbstractPartitionedLimiter.java +++ b/concurrency-limits-core/src/main/java/com/netflix/concurrency/limits/limiter/AbstractPartitionedLimiter.java @@ -225,12 +225,12 @@ private Partition resolvePartition(ContextT context) { @Override public Optional acquire(ContextT context) { - final Partition partition = resolvePartition(context); - if (shouldBypass(context)){ return createBypassListener(); } + final Partition partition = resolvePartition(context); + // This is a little unusual in that the partition is not a hard limit. It is // only a limit that it is applied if the global limit is exceeded. This allows // for excess capacity in each partition to allow for bursting over the limit,