Adding JMX Subscriptions to a Resource

public class JMXSubscriptionClient {

    private static final Log log = LogFactory.getLog(JMXSubscriptionClient.class);
    private static InfoAdminServiceStub stub;
    private static ConfigurationContext itsConfigCtx;
 
//server URL of a running GReg instance
    private static String serverURL = "https://localhost:9443/services/"; 
 
//username and password of that running Greg instance
    private static String username = "admin";
    private static String password = "admin";
    private static String cookie;

    public static void main(String[] args) {
        try {
            // admin service endpoint URL
            String Endpoint = serverURL + "InfoAdminService";

            //creating the configuration context
            Initialization();

            //authenticating and logging to access the service
            authenticate(itsConfigCtx);

            //creating the InfoAdminServiceStub out of the service
            stub = new InfoAdminServiceStub(itsConfigCtx, Endpoint);

            //setting Axis2 options
            ServiceClient client = stub._getServiceClient();
            Options option = client.getOptions();
            option.setManageSession(true);
            option.setProperty(org.apache.axis2.transport.http.HTTPConstants.COOKIE_STRING, cookie);

            try {

                //Add a Subscription to the /_system/governance/clientResource
                SubscriptionBean bean = stub.subscribe("/_system/governance/clientResource", "jmx://", "ResourceUpdated", cookie);

            } catch (RemoteException e) {
                e.printStackTrace();
            } catch (RegistryExceptionException e) {
                String msg = "Error occurred while doing subscription operations";
                log.error(msg, e);
            }

        } catch (AxisFault axisFault) {
            String msg = axisFault.getMessage();
            log.error(msg, axisFault);
        }
    }

    private static boolean authenticate(ConfigurationContext itsConfigCtx) {
        String serviceEPR = serverURL + "AuthenticationAdmin";
        AuthenticationAdminStub stub = null;
        try {
            stub = new AuthenticationAdminStub(itsConfigCtx, serviceEPR);
            ServiceClient client = stub._getServiceClient();
            Options options = client.getOptions();
            options.setManageSession(true);
            try {
                // login to the defined server instance
                boolean result = stub.login(username, password, new URL(serviceEPR).getHost());
                if (result) {
                    cookie = (String) stub._getServiceClient().getServiceContext().getProperty(HTTPConstants.COOKIE_STRING);
                }
                return result;
            } catch (Exception e) {
                String msg = "Error occurred while logging in" + e.getMessage();
                log.error(msg, e);
            }
        } catch (AxisFault axisFault) {
            String msg = axisFault.getMessage();
            log.error(msg, axisFault);
        }
        return false;
    }

    private static void Initialization() {
        // location of the server
        String CARBON_HOME = "/home/test/wso2greg-4.5.0";
        String axis2Repo = CARBON_HOME + File.separator + "repository" + File.separator + "deployment" +
                File.separator + "client";
        String axis2Conf = CARBON_HOME + File.separator + "repository" + File.separator + "conf" + File.separator
                + "axis2" + File.separator + "axis2_client.xml";
        String trustStore = CARBON_HOME + File.separator + "repository" + File.separator + "resources" + File.separator
                + "security" + File.separator + "wso2carbon.jks";
        System.setProperty("javax.net.ssl.trustStore", trustStore);
        System.setProperty("javax.net.ssl.trustStorePassword", "wso2carbon");
        System.setProperty("javax.net.ssl.trustStoreType", "JKS");
        System.setProperty("carbon.repo.write.mode", "true");
        try {
            // creating the configuration context
            itsConfigCtx = ConfigurationContextFactory.createConfigurationContextFromFileSystem(axis2Repo, axis2Conf);

        } catch (AxisFault axisFault) {
            String msg = "An Error occured while creating the Configuration Context" + axisFault.getMessage();
            log.error(msg, axisFault);
        }
    }
}