From d652d0c2b888f6806d2186861a3b2affcdfb7dba Mon Sep 17 00:00:00 2001 From: David Greco Date: Wed, 22 Sep 2010 14:41:19 +0200 Subject: [PATCH] Corrected a bug, now the hbase quorum is read correctly from the configuration --- .../src/main/scala/HbaseStorageBackend.scala | 2 +- .../akka-persistence-hbase/src/test/scala/SimpleHbaseTest.scala | 2 +- config/akka-reference.conf | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/akka-persistence/akka-persistence-hbase/src/main/scala/HbaseStorageBackend.scala b/akka-persistence/akka-persistence-hbase/src/main/scala/HbaseStorageBackend.scala index 4b887add31..69c393f455 100644 --- a/akka-persistence/akka-persistence-hbase/src/main/scala/HbaseStorageBackend.scala +++ b/akka-persistence/akka-persistence-hbase/src/main/scala/HbaseStorageBackend.scala @@ -26,7 +26,7 @@ import org.apache.hadoop.hbase.util.Bytes private[akka] object HbaseStorageBackend extends MapStorageBackend[Array[Byte], Array[Byte]] with VectorStorageBackend[Array[Byte]] with RefStorageBackend[Array[Byte]] with Logging { val EMPTY_BYTE_ARRAY = new Array[Byte](0) - val HBASE_ZOOKEEPER_QUORUM = config.getString("akka.storage.hbase.zookeeper.quorum", "localhost") + val HBASE_ZOOKEEPER_QUORUM = config.getString("akka.storage.hbase.zookeeper-quorum", "localhost") val CONFIGURATION = new HBaseConfiguration val REF_TABLE_NAME = "__REF_TABLE" val VECTOR_TABLE_NAME = "__VECTOR_TABLE" diff --git a/akka-persistence/akka-persistence-hbase/src/test/scala/SimpleHbaseTest.scala b/akka-persistence/akka-persistence-hbase/src/test/scala/SimpleHbaseTest.scala index 82e8f32533..f59e3ae55e 100644 --- a/akka-persistence/akka-persistence-hbase/src/test/scala/SimpleHbaseTest.scala +++ b/akka-persistence/akka-persistence-hbase/src/test/scala/SimpleHbaseTest.scala @@ -48,7 +48,7 @@ class PersistenceSpec extends Spec with BeforeAndAfterAll with ShouldMatchers { import org.apache.hadoop.hbase.client.HBaseAdmin import org.apache.hadoop.hbase.client.HTable - val HBASE_ZOOKEEPER_QUORUM = config.getString("akka.storage.hbase.zookeeper.quorum", "0") + val HBASE_ZOOKEEPER_QUORUM = config.getString("akka.storage.hbase.zookeeper-quorum", "0") HBASE_ZOOKEEPER_QUORUM should not equal ("0") HBASE_ZOOKEEPER_QUORUM should equal("localhost") diff --git a/config/akka-reference.conf b/config/akka-reference.conf index 09e1f39ed3..728f269170 100644 --- a/config/akka-reference.conf +++ b/config/akka-reference.conf @@ -166,7 +166,7 @@ akka { } hbase { - zookeeper.quorum = "localhost" + zookeeper-quorum = "localhost" } } }