# HG changeset patch # User Nobuyasu Oshiro # Date 1389277169 -32400 # Node ID 30717a443cd5b8da185f4693edd979db60c2567d # Parent 80126e22fd0232c60ad01df58e62818f897e74b0 Modified CassandraBulletinBoard for use consistencylevel diff -r 80126e22fd02 -r 30717a443cd5 src/main/java/jp/ac/u_ryukyu/ie/cr/shoshi/jungle/bbs/CassandraBulletinBoard.java --- 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 getBoards() { - Keyspace ksp = HFactory.createKeyspace(keyspace, cluster); + Keyspace ksp = HFactory.createKeyspace(keyspace, cluster, configurableConsistencyLevel); RangeSuperSlicesQuery 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 template = new ThriftSuperCfTemplate(ksp,COLUMN_FAMILY_BOARD,StringSerializer.get(), UUIDSerializer.get(),StringSerializer.get()); @@ -114,7 +114,7 @@ public Iterable getMessages(String _boardName) { - Keyspace ksp = HFactory.createKeyspace(keyspace,cluster); + Keyspace ksp = HFactory.createKeyspace(keyspace, cluster, configurableConsistencyLevel); SuperSliceQuery 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 template = new ThriftSuperCfTemplate(ksp,COLUMN_FAMILY_BOARD,StringSerializer.get(),