[
https://issues.apache.org/jira/browse/APLO-237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christian Posta updated APLO-237:
---------------------------------
Attachment: openwire-tx-leveldb-test.patch
> 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
> Attachments: openwire-tx-leveldb-test.patch
>
>
> 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
