activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r961080 - /activemq/sandbox/activemq-apollo-actor/activemq-tcp/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java
Date Wed, 07 Jul 2010 03:45:47 GMT
Author: chirino
Date: Wed Jul  7 03:45:47 2010
New Revision: 961080

URL: http://svn.apache.org/viewvc?rev=961080&view=rev
Log:
Fixing shutdown loop hang

Modified:
    activemq/sandbox/activemq-apollo-actor/activemq-tcp/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java

Modified: activemq/sandbox/activemq-apollo-actor/activemq-tcp/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/activemq-tcp/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java?rev=961080&r1=961079&r2=961080&view=diff
==============================================================================
--- activemq/sandbox/activemq-apollo-actor/activemq-tcp/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java
(original)
+++ activemq/sandbox/activemq-apollo-actor/activemq-tcp/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java
Wed Jul  7 03:45:47 2010
@@ -255,6 +255,7 @@ public class TcpTransport implements Tra
                 if (oneWay.retained != null) {
                     oneWay.retained.release();
                 }
+                oneWay = outbound.poll();
             }
             setDispatchQueue(null);
             next_outbound_buffer = null;



Mime
View raw message