activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r1235540 - in /activemq/activemq-apollo/trunk: apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/store/ apollo-leveldb/src/main/scala/org/apache/activemq/apollo/broker/store/leveldb/leveldb/
Date Tue, 24 Jan 2012 23:07:56 GMT
Author: chirino
Date: Tue Jan 24 23:07:56 2012
New Revision: 1235540

URL: http://svn.apache.org/viewvc?rev=1235540&view=rev
Log:
Small tweaks

Modified:
    activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/store/DelayingStoreSupport.scala
    activemq/activemq-apollo/trunk/apollo-leveldb/src/main/scala/org/apache/activemq/apollo/broker/store/leveldb/leveldb/LevelDBStore.scala

Modified: activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/store/DelayingStoreSupport.scala
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/store/DelayingStoreSupport.scala?rev=1235540&r1=1235539&r2=1235540&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/store/DelayingStoreSupport.scala
(original)
+++ activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/store/DelayingStoreSupport.scala
Tue Jan 24 23:07:56 2012
@@ -335,11 +335,11 @@ trait DelayingStoreSupport extends Store
     rc.flushed_enqueue_counter = metric_flushed_enqueue_counter
     rc.pending_stores = pending_stores.size
 
-    import collection.JavaConversions._
-    println("--------------")
-    pending_stores.valuesIterator.foreach{ action =>
-      println(action.uow.state+": "+action.uow.uow_id+" "+action.uow.delayable)
-    }
+//    import collection.JavaConversions._
+//    println("--------------")
+//    pending_stores.valuesIterator.foreach{ action =>
+//      println(action.uow.state+": "+action.uow.uow_id+" "+action.uow.delayable)
+//    }
   }
 
   def key(x:QueueEntryRecord) = (x.queue_key, x.entry_seq)

Modified: activemq/activemq-apollo/trunk/apollo-leveldb/src/main/scala/org/apache/activemq/apollo/broker/store/leveldb/leveldb/LevelDBStore.scala
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-leveldb/src/main/scala/org/apache/activemq/apollo/broker/store/leveldb/leveldb/LevelDBStore.scala?rev=1235540&r1=1235539&r2=1235540&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-leveldb/src/main/scala/org/apache/activemq/apollo/broker/store/leveldb/leveldb/LevelDBStore.scala
(original)
+++ activemq/activemq-apollo/trunk/apollo-leveldb/src/main/scala/org/apache/activemq/apollo/broker/store/leveldb/leveldb/LevelDBStore.scala
Tue Jan 24 23:07:56 2012
@@ -267,7 +267,7 @@ class LevelDBStore(val config:LevelDBSto
         rc.index_snapshot_pos = client.last_index_snapshot_pos
         rc.log_stats = {
           var row_layout = "%-20s | %-10s | %-10s\n"
-          row_layout.format("Log File", "Message References", "File Size")+
+          row_layout.format("Log File", "Msg Refs", "File Size")+
           client.log.log_infos.map{case (id,info)=> id -> client.log_refs.get(id).map(_.get)}.toSeq.flatMap
{ case (id, refs)=>
             try {
               val file = LevelDBClient.create_sequence_file(client.directory, id, LevelDBClient.LOG_SUFFIX)



Mime
View raw message