activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Christian Posta (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (APLO-237) Producer transaction using open wire causes hawtdispatch queue assertion error
Date Thu, 09 Aug 2012 20:32:18 GMT

     [ 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

        

Mime
View raw message