diff --git a/src/main/java/com/uber/cadence/internal/worker/PollTaskExecutor.java b/src/main/java/com/uber/cadence/internal/worker/PollTaskExecutor.java
index edf00281f..db8f4104c 100644
--- a/src/main/java/com/uber/cadence/internal/worker/PollTaskExecutor.java
+++ b/src/main/java/com/uber/cadence/internal/worker/PollTaskExecutor.java
@@ -83,7 +83,7 @@ public void process(T task) {
 
   @Override
   public boolean hasCapacity() {
-    return taskExecutor.getActiveCount() < taskExecutor.getPoolSize();
+    return taskExecutor.getActiveCount() < taskExecutor.getMaximumPoolSize();
   }
 
   @Override