Mercurial > hg > Members > shoshi > jungle > bulletinboard

changeset 5:30717a443cd5

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Modified CassandraBulletinBoard for use consistencylevel
author Nobuyasu Oshiro <dimolto@cr.ie.u-ryukyu.ac.jp>
date Thu, 09 Jan 2014 23:19:29 +0900
parents 80126e22fd02
children 406fc1bd3251
files src/main/java/jp/ac/u_ryukyu/ie/cr/shoshi/jungle/bbs/CassandraBulletinBoard.java
diffstat 1 files changed, 4 insertions(+), 4 deletions(-) [+]
line wrap: on
line diff
--- a/src/main/java/jp/ac/u_ryukyu/ie/cr/shoshi/jungle/bbs/CassandraBulletinBoard.java	Thu Jan 09 23:16:00 2014 +0900
+++ b/src/main/java/jp/ac/u_ryukyu/ie/cr/shoshi/jungle/bbs/CassandraBulletinBoard.java	Thu Jan 09 23:19:29 2014 +0900
@@ -68,7 +68,7 @@
 	
 	public Iterable<String> getBoards()
 	{
-		Keyspace ksp = HFactory.createKeyspace(keyspace, cluster);
+		Keyspace ksp = HFactory.createKeyspace(keyspace, cluster, configurableConsistencyLevel);
 		RangeSuperSlicesQuery<String,UUID,String,String> query = HFactory.createRangeSuperSlicesQuery(ksp,StringSerializer.get(),
 				UUIDSerializer.get(),StringSerializer.get(),StringSerializer.get());
 		query.setColumnFamily(COLUMN_FAMILY_BOARD).setKeys(null,null).setRange(null,null,false,0);
@@ -93,7 +93,7 @@
 
 	public void createBoardMessage(UUID _time,String _name,String _author,String _message,String _editKey)
 	{
-		Keyspace ksp = HFactory.createKeyspace(keyspace,cluster);
+		Keyspace ksp = HFactory.createKeyspace(keyspace, cluster, configurableConsistencyLevel);
 		ThriftSuperCfTemplate<String,UUID,String> template = 
 				new ThriftSuperCfTemplate<String,UUID,String>(ksp,COLUMN_FAMILY_BOARD,StringSerializer.get(),
 						UUIDSerializer.get(),StringSerializer.get());
@@ -114,7 +114,7 @@
 
 	public Iterable<BoardMessage> getMessages(String _boardName)
 	{
-		Keyspace ksp = HFactory.createKeyspace(keyspace,cluster);
+		Keyspace ksp = HFactory.createKeyspace(keyspace, cluster, configurableConsistencyLevel);
 		SuperSliceQuery<String, UUID, String, String> query = HFactory.createSuperSliceQuery(ksp, StringSerializer.get(), UUIDSerializer.get(), StringSerializer.get(), StringSerializer.get());
 		
 		UUID start = TimeUUIDUtils.getTimeUUID(0);
@@ -176,7 +176,7 @@
 
 	public void editMessage(String _board,String _uuid,String _author,String _message,String _editKey)
 	{
-		Keyspace ksp = HFactory.createKeyspace(keyspace, cluster);
+		Keyspace ksp = HFactory.createKeyspace(keyspace, cluster, configurableConsistencyLevel);
 		UUID time = UUID.fromString(_uuid);
 		ThriftSuperCfTemplate<String,UUID,String> template = 
 				new ThriftSuperCfTemplate<String,UUID,String>(ksp,COLUMN_FAMILY_BOARD,StringSerializer.get(),