activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r1309439 - /activemq/activemq-apollo/trunk/apollo-stomp/src/main/scala/org/apache/activemq/apollo/stomp/StompProtocolHandler.scala
Date Wed, 04 Apr 2012 15:07:29 GMT
Author: chirino
Date: Wed Apr  4 15:07:29 2012
New Revision: 1309439

URL: http://svn.apache.org/viewvc?rev=1309439&view=rev
Log:
Fixes APLO-182 : "java.lang.AssertionError: Dispatch queue 'hawtdispatch' was not executing"
when sending messages to the broker to many different queues from a single connection.

Modified:
    activemq/activemq-apollo/trunk/apollo-stomp/src/main/scala/org/apache/activemq/apollo/stomp/StompProtocolHandler.scala

Modified: activemq/activemq-apollo/trunk/apollo-stomp/src/main/scala/org/apache/activemq/apollo/stomp/StompProtocolHandler.scala
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-stomp/src/main/scala/org/apache/activemq/apollo/stomp/StompProtocolHandler.scala?rev=1309439&r1=1309438&r2=1309439&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-stomp/src/main/scala/org/apache/activemq/apollo/stomp/StompProtocolHandler.scala
(original)
+++ activemq/activemq-apollo/trunk/apollo-stomp/src/main/scala/org/apache/activemq/apollo/stomp/StompProtocolHandler.scala
Wed Apr  4 15:07:29 2012
@@ -558,7 +558,9 @@ class StompProtocolHandler extends Proto
 
   var producerRoutes = new LRUCache[AsciiBuffer, StompProducerRoute](10) {
     override def onCacheEviction(eldest: Entry[AsciiBuffer, StompProducerRoute]) = {
-      host.router.disconnect(eldest.getValue.addresses, eldest.getValue)
+      host.dispatch_queue {
+        host.router.disconnect(eldest.getValue.addresses, eldest.getValue)
+      }
     }
   }
 



Mime
View raw message