Mercurial > hg > Members > shoshi > TreeCMSv2

comparison src/treecms/cassandra/util/CassandraClientThread.java @ 17:168deb591f21

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
commit
author shoshi
date Tue, 24 May 2011 00:33:12 +0900
parents src/treecms/tree/cassandra/v1/util/CassandraClientThread.java@17ed97ca9960
children
comparison
equal deleted inserted replaced
16:bb9760760744 17:168deb591f21
1 package treecms.cassandra.util;
2
3 import org.apache.thrift.transport.TTransportException;
4
5 /**
6 * CassandraのClientを保持したスレッドオブジェクトです。
7 * @author shoshi
8 */
9 final class CassandraClientThread extends Thread
10 {
11 private CassandraClientWrapper m_wrapper;
12
13 /**
14 * コンストラクタです。
15 * @param _host Cassandraのホスト名
16 * @param _port Cassandraのポート番号
17 * @param _runnable このスレッドで動作するRunnable
18 * @throws TTransportException
19 */
20 private CassandraClientThread(String _host,int _port,Runnable _runnable) throws TTransportException
21 {
22 super(_runnable);
23 m_wrapper = new CassandraClientWrapper(_host,_port,2);
24 }
25
26 /**
27 * ファクトリメソッドです。
28 * @param _host Cassandraのホスト名
29 * @param _port Cassandraのポート番号
30 * @param _runnable このスレッドで動作するRunnable
31 * @return 新しいインスタンス
32 * @throws TTransportException Cassandraへの接続が失敗したとき
33 */
34 public static CassandraClientThread newInstance(String _host,int _port,Runnable _runnable) throws TTransportException
35 {
36 CassandraClientThread thread = new CassandraClientThread(_host,_port,_runnable);
37 return thread;
38 }
39
40 /**
41 * ClientWrapperを取得します
42 * @return CassandraへのClientWrapper
43 */
44 public CassandraClientWrapper getClientWrapper()
45 {
46 return m_wrapper;
47 }
48 }