Christian Posta created APLO-237:
------------------------------------
Summary: Producer transaction using open wire causes hawtdispatch
queue assertion error
Key: APLO-237
URL: https://issues.apache.org/jira/browse/APLO-237
Project: ActiveMQ Apollo
Issue Type: Bug
Components: apollo-openwire
Affects Versions: 1.4
Reporter: Christian Posta
Priority: Minor
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
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators:
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
