diff --git a/activemq-core/src/main/java/org/apache/activemq/state/ConnectionStateTracker.java b/activemq-core/src/main/java/org/apache/activemq/state/ConnectionStateTracker.java
index 86edab46e5..bc384986ba 100755
--- a/activemq-core/src/main/java/org/apache/activemq/state/ConnectionStateTracker.java
+++ b/activemq-core/src/main/java/org/apache/activemq/state/ConnectionStateTracker.java
@@ -78,7 +78,7 @@ public class ConnectionStateTracker extends CommandVisitorAdapter {
             if (result) {
                 if (eldest.getValue() instanceof Message) {
                     currentCacheSize -= ((Message)eldest.getValue()).getSize();
-                } else if (eldest.getValue() instance of MessagePull) {
+                } else if (eldest.getValue() instanceof MessagePull) {
                     currentCacheSize -= 400;
                 }
             }