You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2014/02/05 17:05:07 UTC
git commit: Fixes APLO-303: AssertionError: Use of object not allowed
after it has been released.
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 <hi...@hiramchirino.com>
Authored: Wed Feb 5 11:05:00 2014 -0500
Committer: Hiram Chirino <hi...@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()
}