1 package org.apache.helix;
2 /*
3 * Licensed to the Apache Software Foundation (ASF) under one
4 * or more contributor license agreements. See the NOTICE file
5 * distributed with this work for additional information
6 * regarding copyright ownership. The ASF licenses this file
7 * to you under the Apache License, Version 2.0 (the
8 * "License"); you may not use this file except in compliance
9 * with the License. You may obtain a copy of the License at
10 *
11 * http://www.apache.org/licenses/LICENSE-2.0
12 *
13 * Unless required by applicable law or agreed to in writing,
14 * software distributed under the License is distributed on an
15 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16 * KIND, either express or implied. See the License for the
17 * specific language governing permissions and limitations
18 * under the License.
19 */
20 import org.apache.helix.manager.zk.ZNRecordSerializer;
21 import org.apache.helix.manager.zk.ZkClient;
22 import org.apache.log4j.Logger;
23
24
25 /**
26 * Hello world!
27 *
28 */
29 public class MockRunner
30 {
31
32 private static final Logger logger = Logger.getLogger(MockRunner.class);
33
34 protected static final String nodeType = "EspressoStorage";
35 protected static final String ZK_ADDR = "localhost:2184";
36 protected static final String INSTANCE_NAME = "localhost_1234";
37 protected static final String CLUSTER_NAME = "MockCluster";
38
39 public static void main( String[] args )
40 {
41 //ZkClient zkClient = new ZkClient(ZK_ADDR, 3000, 10000, new ZNRecordSerializer());
42 CMConnector cm = null;
43 try {
44 cm = new CMConnector(CLUSTER_NAME, INSTANCE_NAME, ZK_ADDR); //, zkClient);
45 }
46 catch (Exception e) {
47 logger.error("Unable to initialize CMConnector: "+e);
48 e.printStackTrace();
49 System.exit(-1);
50 }
51 MockNode mock = MockNodeFactory.createMockNode(nodeType, cm);
52 if (mock != null) {
53 mock.run();
54 }
55 else {
56 logger.error("Unknown MockNode type "+nodeType);
57 System.exit(-1);
58 }
59 }
60 }