You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by "Hiram Chirino (JIRA)" <ji...@apache.org> on 2012/09/28 19:55:07 UTC
[jira] [Resolved] (APLO-237) Producer transaction using open wire
causes hawtdispatch queue assertion error
[ https://issues.apache.org/jira/browse/APLO-237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Hiram Chirino resolved APLO-237.
--------------------------------
Resolution: Fixed
Fix Version/s: 1.5
Assignee: Hiram Chirino
Patch /w Test case applied Thanks! Also fixed.
> 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
> Assignee: Hiram Chirino
> Priority: Minor
> Fix For: 1.5
>
> 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
For more information on JIRA, see: http://www.atlassian.com/software/jira