diff --git a/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java b/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
index 9eb5bd712a..681c9524ef 100755
--- a/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
+++ b/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
@@ -99,7 +99,9 @@ public class FailoverTransport implements CompositeTransport {
                 }
                 
             }
-            transportListener.onCommand(command);
+            if (transportListener != null) {
+                transportListener.onCommand(command);
+            }
         }
 
         public void onException(IOException error) {