modules/samples/eventing/src/sample/eventing/Client.java - axis-axis2-java-savan - Git at Google

 /*
  * Copyright 2004,2005 The Apache Software Foundation.
  *
  * Licensed under the Apache License, Version 2.0 (the "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
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */

 package sample.eventing;

 import org.apache.axis2.AxisFault;
 import org.apache.axis2.description.AxisService;
 import org.apache.axis2.transport.http.SimpleHTTPServer;
 import org.apache.axis2.engine.AxisServer;
 import org.apache.axis2.engine.AxisConfiguration;
 import org.apache.axis2.addressing.EndpointReference;
 import org.apache.axis2.client.Options;
 import org.apache.axis2.client.ServiceClient;
 import org.apache.axis2.context.ConfigurationContext;
 import org.apache.axis2.context.ConfigurationContextFactory;
 import org.apache.savan.eventing.client.EventingClient;
 import org.apache.savan.eventing.client.EventingClientBean;
 import org.apache.savan.eventing.client.SubscriptionStatus;

 import java.io.BufferedReader;
 import java.io.IOException;
 import java.io.InputStreamReader;

 public class Client {

     boolean done = false;

     BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));

     private final int MIN_OPTION = 1;
     private final int MAX_OPTION = 9;

     private final String SUBSCRIBER_1_ID = "subscriber1";
     private final String SUBSCRIBER_2_ID = "subscriber2";

     private EventingClient eventingClient = null;

     private String toAddressPart = "/axis2/services/PublisherService";
     private String listener1AddressPart = "/axis2/services/ListenerService1";
     private String listener2AddressPart = "/axis2/services/ListenerService2";

     private static String repo = null;
     private static int port = 8080;
     private static String serverIP = "127.0.0.1";

     private static final String portParam = "-p";
     private static final String repoParam = "-r";
     private static final String helpParam = "-h";

     public static void main(String[] args) throws Exception {

         for (String arg : args) {
             if (helpParam.equalsIgnoreCase(arg)) {
                 displayHelp();
                 System.exit(0);
             }
         }

         String portStr = getParam(portParam, args);
         if (portStr != null) {
             port = Integer.parseInt(portStr);
             System.out.println("Server Port was set to:" + port);
         }

         String repoStr = getParam(repoParam, args);
         if (repoStr != null) {
             repo = repoStr;
             System.out.println("Client Repository was set to:" + repo);
         }

         Client c = new Client();
         c.run();
     }

     private static void displayHelp() {
         System.out.println("Help page for the Eventing Client");
         System.out.println("---------------------------------");
         System.out.println("Set the client reposiory using the parameter -r");
         System.out.println("Set the server port using the parameter -p");
     }

     static void foo() throws Exception {
         ConfigurationContext ctx = ConfigurationContextFactory.createDefaultConfigurationContext();
         SimpleHTTPServer server = new SimpleHTTPServer(ctx, 7071);
         AxisConfiguration axisConfig = ctx.getAxisConfiguration();

 //        AxisService service = new AxisService("ListenerService1");
 //        svc.addParameter("ServiceClass", ListenerService1.class.getName());

         AxisService service = AxisService.createService(ListenerService1.class.getName(),
                                                         axisConfig);
         axisConfig.addService(service);
         server.start();
     }

     /**
      * This will check the given parameter in the array and will return, if available
      *
      * @param param
      * @param args
      * @return
      */
     private static String getParam(String param, String[] args) {
         if (param == null || "".equals(param)) {
             return null;
         }

         for (int i = 0; i < args.length; i = i + 2) {
             String arg = args[i];
             if (param.equalsIgnoreCase(arg) && (args.length >= (i + 1))) {
                 return args[i + 1];
             }
         }
         return null;
     }

     public void run() throws Exception {

         System.out.println("\n");
         System.out.println("Welcome to Axis2 Eventing Sample");
         System.out.println("================================\n");

         foo();

         boolean validOptionSelected = false;
         int selectedOption = -1;
         while (!validOptionSelected) {
             displayMenu();
             selectedOption = getIntInput();
             if (selectedOption >= MIN_OPTION && selectedOption <= MAX_OPTION)
                 validOptionSelected = true;
             else
                 System.out.println("\nInvalid Option \n\n");
         }

         initClient();
         performAction(selectedOption);

         //TODO publish

 //        System.out.println("Press enter to initialize the publisher service.");
 //        reader.readLine();
 //
 //        options.setAction("uuid:DummyMethodAction");
 //        serviceClient.fireAndForget(getDummyMethodRequestElement());

         while (!done) {
             validOptionSelected = false;
             selectedOption = -1;
             while (!validOptionSelected) {
                 displayMenu();
                 selectedOption = getIntInput();
                 if (selectedOption >= MIN_OPTION && selectedOption <= MAX_OPTION)
                     validOptionSelected = true;
                 else
                     System.out.println("\nInvalid Option \n\n");
             }

             performAction(selectedOption);

         }
     }

     private void displayMenu() {
         System.out.println("Press 1 to subscribe Listener Service 1");
         System.out.println("Press 2 to subscribe Listener Service 2");
         System.out.println("Press 3 to subscribe both listener services");
         System.out.println("Press 4 to unsubscribe Listener Service 1");
         System.out.println("Press 5 to unsubscribe Listener Service 2");
         System.out.println("Press 6 to unsubscribe both listener services");
         System.out.println("Press 7 to to get the status of the subscription to Service 1");
         System.out.println("Press 8 to to get the status of the subscription to Service 2");
         System.out.println("Press 9 to Exit");
     }

     private int getIntInput() throws IOException {
         String option = reader.readLine();
         try {
             return Integer.parseInt(option);
         } catch (NumberFormatException e) {
             //invalid option
             return -1;
         }
     }

     private void initClient() throws AxisFault {
         String CLIENT_REPO = null;

         if (repo != null) {
             CLIENT_REPO = repo;
         } else {
 //			throw new AxisFault ("Please specify the client repository as a program argument.Use '-h' for help.");
         }

         ConfigurationContext configContext = ConfigurationContextFactory
                 .createConfigurationContextFromFileSystem(CLIENT_REPO, null);
         ServiceClient serviceClient = new ServiceClient(configContext, null);

         Options options = new Options();
         serviceClient.setOptions(options);
         serviceClient.engageModule("addressing");

         eventingClient = new EventingClient(serviceClient);

         String toAddress = "http://" + serverIP + ":" + port + toAddressPart;
         options.setTo(new EndpointReference(toAddress));
     }

     private void performAction(int action) throws Exception {

         switch (action) {
             case 1:
                 doSubscribe(SUBSCRIBER_1_ID);
                 break;
             case 2:
                 doSubscribe(SUBSCRIBER_2_ID);
                 break;
             case 3:
                 doSubscribe(SUBSCRIBER_1_ID);
                 doSubscribe(SUBSCRIBER_2_ID);
                 break;
             case 4:
                 doUnsubscribe(SUBSCRIBER_1_ID);
                 break;
             case 5:
                 doUnsubscribe(SUBSCRIBER_2_ID);
                 break;
             case 6:
                 doUnsubscribe(SUBSCRIBER_1_ID);
                 doUnsubscribe(SUBSCRIBER_2_ID);
                 break;
             case 7:
                 doGetStatus(SUBSCRIBER_1_ID);
                 break;
             case 8:
                 doGetStatus(SUBSCRIBER_2_ID);
                 break;
             case 9:
                 done = true;
                 break;
             default:
                 break;
         }
     }

     private void doSubscribe(String ID) throws Exception {
         EventingClientBean bean = new EventingClientBean();

         String subscribingAddress = null;
         if (SUBSCRIBER_1_ID.equals(ID)) {
             subscribingAddress = "http://" + serverIP + ":" + 7070 + listener1AddressPart;
         } else if (SUBSCRIBER_2_ID.equals(ID)) {
             subscribingAddress = "http://" + serverIP + ":" + port + listener2AddressPart;
         }

         bean.setDeliveryEPR(new EndpointReference(subscribingAddress));

         //uncomment following to set an expiration time of 10 minutes.
 //		Date date = new Date ();
 //		date.setMinutes(date.getMinutes()+10);
 //		bean.setExpirationTime(date);

         eventingClient.subscribe(bean, ID);
         Thread.sleep(1000);   //TODO remove if not sequired
     }

     private void doUnsubscribe(String ID) throws Exception {
         eventingClient.unsubscribe(ID);
         Thread.sleep(1000);   //TODO remove if not sequired
     }

     private void doGetStatus(String ID) throws Exception {
         SubscriptionStatus status = eventingClient.getSubscriptionStatus(ID);
         Thread.sleep(1000);   //TODO remove if not sequired

         String statusValue = status.getExpirationValue();
         System.out.println("Status of the subscriber '" + ID + "' is" + statusValue);
     }

 //    private OMElement getDummyMethodRequestElement() {
 //        OMFactory fac = OMAbstractFactory.getOMFactory();
 //        OMNamespace namespace = fac.createOMNamespace(applicationNamespaceName, "ns1");
 //        return fac.createOMElement(dummyMethod, namespace);
 //    }

 }
	/*
	* Copyright 2004,2005 The Apache Software Foundation.
	*
	* Licensed under the Apache License, Version 2.0 (the "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
	*
	* Unless required by applicable law or agreed to in writing, software
	* distributed under the License is distributed on an "AS IS" BASIS,
	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	* See the License for the specific language governing permissions and
	* limitations under the License.
	*/

	package sample.eventing;

	import org.apache.axis2.AxisFault;
	import org.apache.axis2.description.AxisService;
	import org.apache.axis2.transport.http.SimpleHTTPServer;
	import org.apache.axis2.engine.AxisServer;
	import org.apache.axis2.engine.AxisConfiguration;
	import org.apache.axis2.addressing.EndpointReference;
	import org.apache.axis2.client.Options;
	import org.apache.axis2.client.ServiceClient;
	import org.apache.axis2.context.ConfigurationContext;
	import org.apache.axis2.context.ConfigurationContextFactory;
	import org.apache.savan.eventing.client.EventingClient;
	import org.apache.savan.eventing.client.EventingClientBean;
	import org.apache.savan.eventing.client.SubscriptionStatus;

	import java.io.BufferedReader;
	import java.io.IOException;
	import java.io.InputStreamReader;

	public class Client {

	boolean done = false;

	BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));

	private final int MIN_OPTION = 1;
	private final int MAX_OPTION = 9;

	private final String SUBSCRIBER_1_ID = "subscriber1";
	private final String SUBSCRIBER_2_ID = "subscriber2";

	private EventingClient eventingClient = null;

	private String toAddressPart = "/axis2/services/PublisherService";
	private String listener1AddressPart = "/axis2/services/ListenerService1";
	private String listener2AddressPart = "/axis2/services/ListenerService2";

	private static String repo = null;
	private static int port = 8080;
	private static String serverIP = "127.0.0.1";

	private static final String portParam = "-p";
	private static final String repoParam = "-r";
	private static final String helpParam = "-h";

	public static void main(String[] args) throws Exception {

	for (String arg : args) {
	if (helpParam.equalsIgnoreCase(arg)) {
	displayHelp();
	System.exit(0);
	}
	}

	String portStr = getParam(portParam, args);
	if (portStr != null) {
	port = Integer.parseInt(portStr);
	System.out.println("Server Port was set to:" + port);
	}

	String repoStr = getParam(repoParam, args);
	if (repoStr != null) {
	repo = repoStr;
	System.out.println("Client Repository was set to:" + repo);
	}

	Client c = new Client();
	c.run();
	}

	private static void displayHelp() {
	System.out.println("Help page for the Eventing Client");
	System.out.println("---------------------------------");
	System.out.println("Set the client reposiory using the parameter -r");
	System.out.println("Set the server port using the parameter -p");
	}

	static void foo() throws Exception {
	ConfigurationContext ctx = ConfigurationContextFactory.createDefaultConfigurationContext();
	SimpleHTTPServer server = new SimpleHTTPServer(ctx, 7071);
	AxisConfiguration axisConfig = ctx.getAxisConfiguration();

	// AxisService service = new AxisService("ListenerService1");
	// svc.addParameter("ServiceClass", ListenerService1.class.getName());

	AxisService service = AxisService.createService(ListenerService1.class.getName(),
	axisConfig);
	axisConfig.addService(service);
	server.start();
	}

	/**
	* This will check the given parameter in the array and will return, if available
	*
	* @param param
	* @param args
	* @return
	*/
	private static String getParam(String param, String[] args) {
	if (param == null \|\| "".equals(param)) {
	return null;
	}

	for (int i = 0; i < args.length; i = i + 2) {
	String arg = args[i];
	if (param.equalsIgnoreCase(arg) && (args.length >= (i + 1))) {
	return args[i + 1];
	}
	}
	return null;
	}

	public void run() throws Exception {

	System.out.println("\n");
	System.out.println("Welcome to Axis2 Eventing Sample");
	System.out.println("================================\n");

	foo();

	boolean validOptionSelected = false;
	int selectedOption = -1;
	while (!validOptionSelected) {
	displayMenu();
	selectedOption = getIntInput();
	if (selectedOption >= MIN_OPTION && selectedOption <= MAX_OPTION)
	validOptionSelected = true;
	else
	System.out.println("\nInvalid Option \n\n");
	}

	initClient();
	performAction(selectedOption);

	//TODO publish

	// System.out.println("Press enter to initialize the publisher service.");
	// reader.readLine();
	//
	// options.setAction("uuid:DummyMethodAction");
	// serviceClient.fireAndForget(getDummyMethodRequestElement());

	while (!done) {
	validOptionSelected = false;
	selectedOption = -1;
	while (!validOptionSelected) {
	displayMenu();
	selectedOption = getIntInput();
	if (selectedOption >= MIN_OPTION && selectedOption <= MAX_OPTION)
	validOptionSelected = true;
	else
	System.out.println("\nInvalid Option \n\n");
	}

	performAction(selectedOption);

	}
	}

	private void displayMenu() {
	System.out.println("Press 1 to subscribe Listener Service 1");
	System.out.println("Press 2 to subscribe Listener Service 2");
	System.out.println("Press 3 to subscribe both listener services");
	System.out.println("Press 4 to unsubscribe Listener Service 1");
	System.out.println("Press 5 to unsubscribe Listener Service 2");
	System.out.println("Press 6 to unsubscribe both listener services");
	System.out.println("Press 7 to to get the status of the subscription to Service 1");
	System.out.println("Press 8 to to get the status of the subscription to Service 2");
	System.out.println("Press 9 to Exit");
	}

	private int getIntInput() throws IOException {
	String option = reader.readLine();
	try {
	return Integer.parseInt(option);
	} catch (NumberFormatException e) {
	//invalid option
	return -1;
	}
	}

	private void initClient() throws AxisFault {
	String CLIENT_REPO = null;

	if (repo != null) {
	CLIENT_REPO = repo;
	} else {
	// throw new AxisFault ("Please specify the client repository as a program argument.Use '-h' for help.");
	}

	ConfigurationContext configContext = ConfigurationContextFactory
	.createConfigurationContextFromFileSystem(CLIENT_REPO, null);
	ServiceClient serviceClient = new ServiceClient(configContext, null);

	Options options = new Options();
	serviceClient.setOptions(options);
	serviceClient.engageModule("addressing");

	eventingClient = new EventingClient(serviceClient);

	String toAddress = "http://" + serverIP + ":" + port + toAddressPart;
	options.setTo(new EndpointReference(toAddress));
	}

	private void performAction(int action) throws Exception {

	switch (action) {
	case 1:
	doSubscribe(SUBSCRIBER_1_ID);
	break;
	case 2:
	doSubscribe(SUBSCRIBER_2_ID);
	break;
	case 3:
	doSubscribe(SUBSCRIBER_1_ID);
	doSubscribe(SUBSCRIBER_2_ID);
	break;
	case 4:
	doUnsubscribe(SUBSCRIBER_1_ID);
	break;
	case 5:
	doUnsubscribe(SUBSCRIBER_2_ID);
	break;
	case 6:
	doUnsubscribe(SUBSCRIBER_1_ID);
	doUnsubscribe(SUBSCRIBER_2_ID);
	break;
	case 7:
	doGetStatus(SUBSCRIBER_1_ID);
	break;
	case 8:
	doGetStatus(SUBSCRIBER_2_ID);
	break;
	case 9:
	done = true;
	break;
	default:
	break;
	}
	}

	private void doSubscribe(String ID) throws Exception {
	EventingClientBean bean = new EventingClientBean();

	String subscribingAddress = null;
	if (SUBSCRIBER_1_ID.equals(ID)) {
	subscribingAddress = "http://" + serverIP + ":" + 7070 + listener1AddressPart;
	} else if (SUBSCRIBER_2_ID.equals(ID)) {
	subscribingAddress = "http://" + serverIP + ":" + port + listener2AddressPart;
	}

	bean.setDeliveryEPR(new EndpointReference(subscribingAddress));

	//uncomment following to set an expiration time of 10 minutes.
	// Date date = new Date ();
	// date.setMinutes(date.getMinutes()+10);
	// bean.setExpirationTime(date);

	eventingClient.subscribe(bean, ID);
	Thread.sleep(1000); //TODO remove if not sequired
	}

	private void doUnsubscribe(String ID) throws Exception {
	eventingClient.unsubscribe(ID);
	Thread.sleep(1000); //TODO remove if not sequired
	}

	private void doGetStatus(String ID) throws Exception {
	SubscriptionStatus status = eventingClient.getSubscriptionStatus(ID);
	Thread.sleep(1000); //TODO remove if not sequired

	String statusValue = status.getExpirationValue();
	System.out.println("Status of the subscriber '" + ID + "' is" + statusValue);
	}

	// private OMElement getDummyMethodRequestElement() {
	// OMFactory fac = OMAbstractFactory.getOMFactory();
	// OMNamespace namespace = fac.createOMNamespace(applicationNamespaceName, "ns1");
	// return fac.createOMElement(dummyMethod, namespace);
	// }

	}