[APLO-357] non-fatal NullPointerException when manually deleting a queue

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Won't Do
• Affects Version/s: 1.7
• Component/s: apollo-broker

Environment

Operating System:
{code}
Name: Linux 3.10.35-43.137.amzn1.x86_64
Architecture: amd64
Processor Cores: 2
Memory Free/Total: 959.86 mb / 7.06 gb
Swap Used/Available: 0 bytes / 0 bytes
FD Open/Max: 271 / 100000
Load Average: 0.05
{code}

Java Virtual Machine
{code}
Version: OpenJDK 64-Bit Server VM 1.7.0_55 (Oracle Corporation)
Up Time: 95848.71 seconds
Heap Memory: 165.08 mb / 442.50 mb
Non-Heap Memory: 51.30 mb / 52.31 mb
Threads: 21
{code}

• Assignee: Unassigned
• Reporter: Daniel Miles
• Created: 24/Jun/14 17:26
• Updated: 06/Apr/22 19:16
• Resolved: 06/Apr/22 19:16

Description

We deleted a queue that had no messages, no producers and no consumers. The stack-trace is brutally short:

java.lang.NullPointerException
        at org.apache.activemq.apollo.broker.LocalRouter$$anonfun$_destroy_queue$1$$anonfun$apply$mcV$sp$2.apply$mcV$sp(LocalRouter.scala:1359)
        at org.fusesource.hawtdispatch.package$$anon$4.run(hawtdispatch.scala:357)
        at org.fusesource.hawtdispatch.internal.SerialDispatchQueue.run(SerialDispatchQueue.java:100)
        at org.fusesource.hawtdispatch.internal.pool.SimpleThread.run(SimpleThread.java:77)

It is preceeded by a huge number of AssertionErrors, but we don't think they are related:

java.lang.AssertionError: queue:store: Use of object not allowed after it has been released.
        at org.fusesource.hawtdispatch.BaseRetained.assertRetained(BaseRetained.java:172)
        at org.fusesource.hawtdispatch.BaseRetained.retain(BaseRetained.java:94)
        at org.apache.activemq.apollo.broker.DeliveryProducerRoute$$anonfun$bind$2.apply(Router.scala:236)
        at org.apache.activemq.apollo.broker.DeliveryProducerRoute$$anonfun$bind$2.apply(Router.scala:236)
        at scala.collection.immutable.List.foreach(List.scala:309)
        at org.apache.activemq.apollo.broker.DeliveryProducerRoute.bind(Router.scala:236)
        at org.apache.activemq.apollo.broker.Queue.connect(Queue.scala:1333)
        at org.apache.activemq.apollo.broker.LocalRouter$Domain$$anonfun$connect$1.apply(LocalRouter.scala:489)
        at org.apache.activemq.apollo.broker.LocalRouter$Domain$$anonfun$connect$1.apply(LocalRouter.scala:487)
        at scala.collection.Iterator$class.foreach(Iterator.scala:727)
        at scala.collection.AbstractIterator.foreach(Iterator.scala:1156)
        at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
        at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
        at org.apache.activemq.apollo.broker.LocalRouter$Domain$class.connect(LocalRouter.scala:487)
        at org.apache.activemq.apollo.broker.LocalRouter$QueueDomain.connect(LocalRouter.scala:752)
        at org.apache.activemq.apollo.broker.LocalRouter$$anonfun$11.org$apache$activemq$apollo$broker$LocalRouter$$anonfun$$perform$5(LocalRouter.scala:1102)
        at org.apache.activemq.apollo.broker.LocalRouter$$anonfun$11$$anonfun$apply$7.apply$mcV$sp(LocalRouter.scala:1103)
        at org.apache.activemq.apollo.broker.LocalRouter$$anonfun$connect$2.apply(LocalRouter.scala:1116)
        at org.apache.activemq.apollo.broker.LocalRouter$$anonfun$connect$2.apply(LocalRouter.scala:1116)
        at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
        at scala.collection.mutable.ArrayOps$ofRef.foreach(ArrayOps.scala:105)
        at org.apache.activemq.apollo.broker.LocalRouter.connect(LocalRouter.scala:1116)
        at org.apache.activemq.apollo.stomp.StompProtocolHandler$$anonfun$perform_send$1.apply$mcV$sp(StompProtocolHandler.scala:1331)
        at org.fusesource.hawtdispatch.package$$anon$4.run(hawtdispatch.scala:357)
        at org.fusesource.hawtdispatch.internal.SerialDispatchQueue.run(SerialDispatchQueue.java:100)
        at org.fusesource.hawtdispatch.internal.pool.SimpleThread.run(SimpleThread.java:77)