Unnecessary log removal (#2208)
[helix.git] / recipes / rabbitmq-consumer-group / src / main / java / org / apache / helix / recipes / rabbitmq / SetupConsumerCluster.java
index bfc3149646e584ac02142f47918c6e0199075edf..c676272b19b070ab49bfe813d5be9513be4c57d5 100644 (file)
@@ -9,7 +9,7 @@ package org.apache.helix.recipes.rabbitmq;
  * "License"); you may not use this file except in compliance
  * with the License.  You may obtain a copy of the License at
  *
- *   http://www.apache.org/licenses/LICENSE-2.0
+ *     http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing,
  * software distributed under the License is distributed on an
@@ -21,7 +21,7 @@ package org.apache.helix.recipes.rabbitmq;
 
 import org.apache.helix.manager.zk.ZKHelixAdmin;
 import org.apache.helix.manager.zk.ZNRecordSerializer;
-import org.apache.helix.manager.zk.ZkClient;
+import org.apache.helix.zookeeper.impl.client.ZkClient;
 import org.apache.helix.model.IdealState.RebalanceMode;
 import org.apache.helix.model.StateModelDefinition;
 import org.apache.helix.tools.StateModelConfigGenerator;
@@ -52,9 +52,8 @@ public class SetupConsumerCluster {
       admin.addCluster(clusterName, true);
 
       // add state model definition
-      StateModelConfigGenerator generator = new StateModelConfigGenerator();
       admin.addStateModelDef(clusterName, DEFAULT_STATE_MODEL,
-          new StateModelDefinition(generator.generateConfigForOnlineOffline()));
+          new StateModelDefinition(StateModelConfigGenerator.generateConfigForOnlineOffline()));
 
       // add resource "topic" which has 6 partitions
       String resourceName = DEFAULT_RESOURCE_NAME;