modules/helpers/metrics-simulator/src/main/java/org/rhq/metrics/simulator/Simulator.java | 14 +++++++--- 1 file changed, 11 insertions(+), 3 deletions(-)
New commits: commit 98030d80f768f87aa2eecf91b64f5b7c8e3b2240 Author: John Sanda jsanda@redhat.com Date: Thu Mar 14 12:38:37 2013 -0400
do not use hard coded hostnames when creating session for simulator
diff --git a/modules/helpers/metrics-simulator/src/main/java/org/rhq/metrics/simulator/Simulator.java b/modules/helpers/metrics-simulator/src/main/java/org/rhq/metrics/simulator/Simulator.java index 8901538..7cb1fbf 100644 --- a/modules/helpers/metrics-simulator/src/main/java/org/rhq/metrics/simulator/Simulator.java +++ b/modules/helpers/metrics-simulator/src/main/java/org/rhq/metrics/simulator/Simulator.java @@ -72,7 +72,7 @@ public class Simulator implements ShutdownManager { public void run(SimulationPlan plan) { List<CassandraNode> nodes = initCluster(plan); createSchema(nodes); - Session session = createSession(); + Session session = createSession(nodes);
MetricsServer metricsServer = new MetricsServer(); metricsServer.setSession(session); @@ -200,13 +200,13 @@ public class Simulator implements ShutdownManager { } }
- private Session createSession() throws NoHostAvailableException { + private Session createSession(List<CassandraNode> nodes) throws NoHostAvailableException { try { SimpleAuthInfoProvider authInfoProvider = new SimpleAuthInfoProvider(); authInfoProvider.add("username", "rhqadmin").add("password", "rhqadmin");
Cluster cluster = Cluster.builder() - .addContactPoints("127.0.0.1", "127.0.0.2") + .addContactPoints(getHostNames(nodes)) .withAuthInfoProvider(authInfoProvider) .withCompression(SNAPPY) .build(); @@ -222,6 +222,14 @@ public class Simulator implements ShutdownManager { } }
+ private String[] getHostNames(List<CassandraNode> nodes) { + String[] hostnames = new String[nodes.size()]; + for (int i = 0; i < hostnames.length; ++i) { + hostnames[i] = nodes.get(i).getHostName(); + } + return hostnames; + } + private Set<Schedule> initSchedules(ScheduleGroup scheduleSet) { long nextCollection = System.currentTimeMillis(); Set<Schedule> schedules = new HashSet<Schedule>();
rhq-commits@lists.fedorahosted.org