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 <[email protected]> Authored: Wed Feb 5 11:05:00 2014 -0500 Committer: Hiram Chirino <[email protected]> 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() }
