Mercurial > hg > Members > shoshi > TreeCMSv2

diff src/treecms/tree/cassandra/v1/CassandraForest.java @ 9:17ed97ca9960

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
commit
author shoshi
date Mon, 18 Apr 2011 01:07:27 +0900
parents f96193babac0
children bb9760760744
line wrap: on
line diff
--- a/src/treecms/tree/cassandra/v1/CassandraForest.java	Thu Mar 31 02:08:44 2011 +0900
+++ b/src/treecms/tree/cassandra/v1/CassandraForest.java	Mon Apr 18 01:07:27 2011 +0900
@@ -35,6 +35,7 @@
 import treecms.api.Node;
 import treecms.api.NodeData;
 import treecms.api.NodeID;
+import treecms.tree.cassandra.v1.util.CassandraClientThreadFactory;
 import treecms.tree.id.AbstractRandomNodeID;
 
 /**
@@ -78,7 +79,7 @@
 	
 	public CassandraForest(String _host,int _port,String _ks,int _threads)
 	{
-		m_service = Executors.newFixedThreadPool(_threads,new ClientThreadFactory(_host,_port));
+		m_service = Executors.newFixedThreadPool(_threads,new CassandraClientThreadFactory(_host,_port));
 		
 		m_cache = new ConcurrentHashMap<NodeID,CassandraNode>();
 		m_tipCache = new ConcurrentHashMap<String,CassandraNode>();