svn commit: r1032139 - /activemq/activemq-apollo/trunk/apollo-bdb/src/main/scala/org/apache/activemq/apollo/store/bdb/BDBStore.scala

[ch...@apache.org]

Author: chirino
Date: Sat Nov  6 20:55:16 2010
New Revision: 1032139

URL: http://svn.apache.org/viewvc?rev=1032139&view=rev
Log:
better bdb store thread/queue identification.

Modified:
    activemq/activemq-apollo/trunk/apollo-bdb/src/main/scala/org/apache/activemq/apollo/store/bdb/BDBStore.scala

Modified: activemq/activemq-apollo/trunk/apollo-bdb/src/main/scala/org/apache/activemq/apollo/store/bdb/BDBStore.scala
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-bdb/src/main/scala/org/apache/activemq/apollo/store/bdb/BDBStore.scala?rev=1032139&r1=1032138&r2=1032139&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-bdb/src/main/scala/org/apache/activemq/apollo/store/bdb/BDBStore.scala (original)
+++ activemq/activemq-apollo/trunk/apollo-bdb/src/main/scala/org/apache/activemq/apollo/store/bdb/BDBStore.scala Sat Nov  6 20:55:16 2010
@@ -28,6 +28,9 @@ import ReporterLevel._
 import org.fusesource.hawtdispatch.ListEventAggregator
 import org.apache.activemq.apollo.dto.{StoreStatusDTO, IntMetricDTO, TimeMetricDTO, StoreDTO}
 
+/**
+ * @author <a href="http://hiramchirino.com">Hiram Chirino</a>
+ */
 object BDBStore extends Log {
   val DATABASE_LOCKED_WAIT_DELAY = 10 * 1000;
 
@@ -68,7 +71,7 @@ class BDBStore extends DelayingStoreSupp
   var config:BDBStoreDTO = defaultConfig
   val client = new BDBClient(this)
 
-  override def toString = "hawtdb store"
+  override def toString = "bdb store"
 
   def flush_delay = config.flush_delay
   
@@ -100,7 +103,7 @@ class BDBStore extends DelayingStoreSupp
   protected def _start(onCompleted: Runnable) = {
     executor_pool = Executors.newFixedThreadPool(1, new ThreadFactory(){
       def newThread(r: Runnable) = {
-        val rc = new Thread(r, "hawtdb store client")
+        val rc = new Thread(r, toString+" io")
         rc.setDaemon(true)
         rc
       }