CollStorm.java 1.59 KB
package com.sitech.ismp.coll.centercoll;

import java.util.HashMap;
import java.util.Vector;

/**
 * Created with IntelliJ IDEA.
 * User: ZhouYou
 * Date: 15-6-25
 * Time: 上午11:53
 * To change this template use File | Settings | File Templates.
 */
public class CollStorm implements CollStormMBean {

    public Vector getStormClusterInfo(HashMap params) {
        CollStormWithCMD stormCluster = new CollStormWithCMD();
        return stormCluster.getStormClusterInfo(params);
    }

    public static void main(String[] args) {
        System.out.println("***************StormCluster Collect Test Begin*********************");
        String hostIP = "10.243.29.28";
        String version = "0.9.3";
        String stormPort = "6627";
        String fileDir = "6627";
        String topoFileDir = "6627";
        System.out.println("HostIP=" + hostIP + ", version=" + version
                + ",stormPort=" + stormPort);
        HashMap<String, String> params = new HashMap<String, String>();
        params.put("HOSTIP", hostIP);
//        params.put("version", version);
        params.put("STORMPORT", stormPort);
        params.put("FILEDIR", fileDir);
        params.put("TOPOFILEDIR", topoFileDir);

        CollStorm collector = new CollStorm();
        String methodStr = "0";
        int method = Integer.parseInt(methodStr);
        switch (method) {
            case 0:
                collector.getStormClusterInfo(params);
                break;
            default:
                break;
        }
        System.out.println("***************StormCluster Collect Test End*********************");
    }
}