activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r372519 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
Date Thu, 26 Jan 2006 12:40:15 GMT
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()));
             }



Mime
View raw message