From 40ce55be77effd7a07010cd04e8f9582ca4377eb Mon Sep 17 00:00:00 2001
From: James Strachan <jstrachan@apache.org>
Date: Thu, 26 Jan 2006 12:40:12 +0000
Subject: [PATCH] added extra NPE check

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@372519 13f79535-47bb-0310-9956-ffa450edef68
---
 .../apache/activemq/transport/failover/FailoverTransport.java  | 3 +++
 1 file changed, 3 insertions(+)

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 83e74d183f..9eb5bd712a 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
@@ -79,6 +79,9 @@ public class FailoverTransport implements CompositeTransport {
 
     private final TransportListener myTransportListener = new TransportListener() {
         public void onCommand(Command command) {
+            if (command == null) {
+                return;
+            }
             if (command.isResponse()) {
                 requestMap.remove(new Short(((Response) command).getCorrelationId()));
             }