svn commit: r372519 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java

[jstrachan]

Author: jstrachan
Date: Thu Jan 26 04:40:12 2006
New Revision: 372519

URL: http://svn.apache.org/viewcvs?rev=372519&view=rev
Log:
added extra NPE check

Modified:
    
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java

Modified: 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
URL: 
http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java?rev=372519&r1=372518&r2=372519&view=diff
==============================================================================
--- 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
 (original)
+++ 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
 Thu Jan 26 04:40:12 2006
@@ -79,6 +79,9 @@
 
     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()));
             }