modules/common/cassandra-common-itests/src/main/java/org/rhq/cassandra/CassandraClusterManager.java
| 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
New commits:
commit 9a5d18c2acded42012c9bf76ffb7038016a3ea95
Author: John Sanda <jsanda(a)redhat.com>
Date: Sat Dec 15 17:49:54 2012 -0500
checking if schema exists before creating it
diff --git
a/modules/common/cassandra-common-itests/src/main/java/org/rhq/cassandra/CassandraClusterManager.java
b/modules/common/cassandra-common-itests/src/main/java/org/rhq/cassandra/CassandraClusterManager.java
index f2aca9c..0dd25f5 100644
---
a/modules/common/cassandra-common-itests/src/main/java/org/rhq/cassandra/CassandraClusterManager.java
+++
b/modules/common/cassandra-common-itests/src/main/java/org/rhq/cassandra/CassandraClusterManager.java
@@ -120,8 +120,11 @@ public class CassandraClusterManager implements
IInvokedMethodListener {
String[] hostNames = getHostNames(deployer.getCassandraHosts());
SchemaManager schemaManager = new SchemaManager(annotation.username(),
annotation.password(), hostNames);
- schemaManager.createSchema();
+ if (!schemaManager.schemaExists()) {
+ schemaManager.createSchema();
+ }
schemaManager.updateSchema();
+ schemaManager.shutdown();
}
private void shutdownCluster() throws Exception {
Show replies by date