cluster_ = (ClusterImpl)getCluster(); clusterId_ = cluster_.getClusterIdentifier();
clusterId_ = getClusterIdentifier();
    protected void setupSubscriptions() { 	parseArguments();	initializeDriver();	cluster_ = (ClusterImpl)getCluster(); 	clusterId_ = cluster_.getClusterIdentifier();	className_ = this.getClass().getName();	int indx = className_.lastIndexOf(".");	if (indx > -1) {	    className_ = className_.substring(indx+1);	}    }