[APLO-237] Producer transaction using open wire causes hawtdispatch queue assertion error

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.4
• Fix Version/s: 1.5
• Component/s: apollo-openwire
• Assignee: Hiram R. Chirino
• Reporter: Christian Posta
• Created: 09/Aug/12 20:29
• Updated: 28/Sep/12 17:54
• Resolved: 28/Sep/12 17:54

Description

See test I added (attached). Running the "OpenwireLevelDBTransactionTest" seems to cause this:

Exception in thread "hawtdispatch-DEFAULT-1" java.lang.AssertionError: Dispatch queue 'connection 1 to /127.0.0.1:51529' was not executing, (currently executing: 'leveldb store at /Users/cposta/dev/idea-workspace/activemq-apollo/apollo-openwire/target/test-data/org.apache.activemq.apollo.openwire.test.OpenwireLevelDBTransactionTest')
at org.fusesource.hawtdispatch.internal.SerialDispatchQueue.assertExecuting(SerialDispatchQueue.java:141)
at org.fusesource.hawtdispatch.transport.TcpTransport.offer(TcpTransport.java:541)
at org.apache.activemq.apollo.broker.TransportSink.offer(Sink.scala:107)
at org.apache.activemq.apollo.broker.SinkMapper$class.offer(Sink.scala:88)
at org.apache.activemq.apollo.broker.Sink$$anon$1.offer(Sink.scala:54)
at org.apache.activemq.apollo.broker.SinkMux$ManagedSink.offer(Sink.scala:244)
at org.apache.activemq.apollo.broker.OverflowSink.offer(Sink.scala:168)
at org.apache.activemq.apollo.openwire.OpenwireProtocolHandler.ack(OpenwireProtocolHandler.scala:185)
at org.apache.activemq.apollo.openwire.OpenwireProtocolHandler$$anonfun$on_transaction_info$1.apply$mcV$sp(OpenwireProtocolHandler.scala:549)
at org.apache.activemq.apollo.broker.store.StoreUOW$$anonfun$on_complete$1.apply(StoreUOW.scala:89)
at org.apache.activemq.apollo.broker.store.StoreUOW$$anonfun$on_complete$1.apply(StoreUOW.scala:89)
at org.apache.activemq.apollo.broker.store.DelayingStoreSupport$DelayableUOW$$anonfun$on_completed$1.apply(DelayingStoreSupport.scala:286)
at org.apache.activemq.apollo.broker.store.DelayingStoreSupport$DelayableUOW$$anonfun$on_completed$1.apply(DelayingStoreSupport.scala:286)
at scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:59)
at scala.collection.immutable.List.foreach(List.scala:45)
at scala.collection.generic.TraversableForwarder$class.foreach(TraversableForwarder.scala:30)
at scala.collection.mutable.ListBuffer.foreach(ListBuffer.scala:42)
at org.apache.activemq.apollo.broker.store.DelayingStoreSupport$DelayableUOW.on_completed(DelayingStoreSupport.scala:286)
at org.apache.activemq.apollo.broker.store.DelayingStoreSupport$$anonfun$store_completed$1.apply(DelayingStoreSupport.scala:536)
at org.apache.activemq.apollo.broker.store.DelayingStoreSupport$$anonfun$store_completed$1.apply(DelayingStoreSupport.scala:535)
at scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:59)
at scala.collection.immutable.List.foreach(List.scala:45)
at scala.collection.generic.TraversableForwarder$class.foreach(TraversableForwarder.scala:30)
at scala.collection.mutable.ListBuffer.foreach(ListBuffer.scala:42)
at org.apache.activemq.apollo.broker.store.DelayingStoreSupport$class.store_completed(DelayingStoreSupport.scala:535)
at org.apache.activemq.apollo.broker.store.leveldb.LevelDBStore.store_completed(LevelDBStore.scala:44)
at org.apache.activemq.apollo.broker.store.DelayingStoreSupport$$anonfun$drain_flushes$1$$anonfun$apply$1.apply$mcV$sp(DelayingStoreSupport.scala:514)
at org.fusesource.hawtdispatch.package$$anon$3.run(hawtdispatch.scala:357)
at org.fusesource.hawtdispatch.internal.SerialDispatchQueue.run(SerialDispatchQueue.java:96)
at org.fusesource.hawtdispatch.internal.pool.SimpleThread.run(SimpleThread.java:77)
org.apache.activemq.transport.InactivityMonitor TRACE | A receive is in progress
org.apache.activemq.transport.InactivityMonitor TRACE | tcp://localhost/127.0.0.1:51527 message sent since last write check, resetting flag