You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by js...@apache.org on 2006/01/26 13:40:15 UTC
svn commit: r372519 -
/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
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()));
}