activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject git commit: Fixes APLO-303: AssertionError: Use of object not allowed after it has been released.
Date Wed, 05 Feb 2014 16:05:07 GMT
Updated Branches:
  refs/heads/trunk 989384b37 -> 2b3b5ccb9


Fixes APLO-303: AssertionError: Use of object not allowed after it has been released.

Project: http://git-wip-us.apache.org/repos/asf/activemq-apollo/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-apollo/commit/2b3b5ccb
Tree: http://git-wip-us.apache.org/repos/asf/activemq-apollo/tree/2b3b5ccb
Diff: http://git-wip-us.apache.org/repos/asf/activemq-apollo/diff/2b3b5ccb

Branch: refs/heads/trunk
Commit: 2b3b5ccb91447c1577da0993123ff57a7bd58c31
Parents: 989384b
Author: Hiram Chirino <hiram@hiramchirino.com>
Authored: Wed Feb 5 11:05:00 2014 -0500
Committer: Hiram Chirino <hiram@hiramchirino.com>
Committed: Wed Feb 5 11:05:00 2014 -0500

----------------------------------------------------------------------
 .../org/apache/activemq/apollo/amqp/AmqpProtocolHandler.scala      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-apollo/blob/2b3b5ccb/apollo-amqp/src/main/scala/org/apache/activemq/apollo/amqp/AmqpProtocolHandler.scala
----------------------------------------------------------------------
diff --git a/apollo-amqp/src/main/scala/org/apache/activemq/apollo/amqp/AmqpProtocolHandler.scala
b/apollo-amqp/src/main/scala/org/apache/activemq/apollo/amqp/AmqpProtocolHandler.scala
index 73935c3..562756e 100644
--- a/apollo-amqp/src/main/scala/org/apache/activemq/apollo/amqp/AmqpProtocolHandler.scala
+++ b/apollo-amqp/src/main/scala/org/apache/activemq/apollo/amqp/AmqpProtocolHandler.scala
@@ -459,11 +459,11 @@ class AmqpProtocolHandler extends ProtocolHandler {
         case route: AmqpProducerRoute =>
           // Lets disconnect the route.
           set_attachment(receiver, null)
+          producers -= route.id
           host.dispatch_queue {
             host.router.disconnect(route.addresses, route)
             queue {
               receiver.close()
-              producers -= route.id
               route.release
               onComplete.run()
             }


Mime
View raw message