Author: prabath Date: Mon Dec 22 12:42:16 2008 New Revision: 27685 URL: http://wso2.org/svn/browse/wso2?view=rev&revision=27685
Log: CARBON-1750 Modified: trunk/wsas/java/modules/samples/Eventing/client/src/org/wso2/wsas/sample/eventing/Client.java Modified: trunk/wsas/java/modules/samples/Eventing/client/src/org/wso2/wsas/sample/eventing/Client.java URL: http://wso2.org/svn/browse/wso2/trunk/wsas/java/modules/samples/Eventing/client/src/org/wso2/wsas/sample/eventing/Client.java?rev=27685&r1=27684&r2=27685&view=diff ============================================================================== --- trunk/wsas/java/modules/samples/Eventing/client/src/org/wso2/wsas/sample/eventing/Client.java (original) +++ trunk/wsas/java/modules/samples/Eventing/client/src/org/wso2/wsas/sample/eventing/Client.java Mon Dec 22 12:42:16 2008 @@ -3,6 +3,7 @@ import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; +import java.util.Date; import org.apache.axiom.om.OMAbstractFactory; import org.apache.axiom.om.OMElement; @@ -16,6 +17,7 @@ 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; public class Client { @@ -32,7 +34,8 @@ return; } - confContext = ConfigurationContextFactory.createConfigurationContextFromFileSystem("repository"); + confContext = ConfigurationContextFactory + .createConfigurationContextFromFileSystem("repository"); client = new ServiceClient(confContext, null); client.engageModule("addressing"); @@ -43,23 +46,29 @@ displayMenu(); option = getIntInput(); switch (option) { - case 1: - startPublishing(client, args[0]); - break; - case 2: - subscribe(client, args[0], args[1]); - break; - case 3: - unsubscribe(); - break; - case 4: - stopPublishing(client, args[0]); - break; - case 5: - goahead = false; - break; - default: - goahead = false; + case 1 : + startPublishing(client, args[0]); + break; + case 2 : + subscribe(client, args[0], args[1]); + break; + case 3 : + renew(); + break; + case 4 : + getStatus(); + break; + case 5 : + unsubscribe(); + break; + case 6 : + stopPublishing(client, args[0]); + break; + case 7 : + goahead = false; + break; + default : + goahead = false; } } } @@ -67,9 +76,11 @@ private static void displayMenu() { System.out.println("Press 1 to start publishing"); System.out.println("Press 2 to subscribe"); - System.out.println("Press 3 to unsubscribe"); - System.out.println("Press 4 to stop publishing"); - System.out.println("Press 5 to Exit"); + System.out.println("Press 3 to renew"); + System.out.println("Press 4 to get status"); + System.out.println("Press 5 to unsubscribe"); + System.out.println("Press 6 to stop publishing"); + System.out.println("Press 7 to Exit"); } private static int getIntInput() throws IOException { @@ -104,6 +115,28 @@ eventingClient.subscribe(bean, SUBSCRIBER_ID); } + private static void renew() throws Exception { + + if (eventingClient == null) { + System.out.println("You need to subscribe first"); + return; + } + + eventingClient.renewSubscription(new Date(2010, 12, 12), SUBSCRIBER_ID); + } + + private static void getStatus() throws Exception { + + SubscriptionStatus status = null; + + if (eventingClient == null) { + System.out.println("You need to subscribe first"); + return; + } + status = eventingClient.getSubscriptionStatus(SUBSCRIBER_ID); + System.out.println(status.getExpirationValue()); + } + private static void unsubscribe() throws Exception { if (eventingClient != null) { eventingClient.unsubscribe(SUBSCRIBER_ID); _______________________________________________ Wsas-java-dev mailing list [email protected] https://wso2.org/cgi-bin/mailman/listinfo/wsas-java-dev
