From ac852857fd4ee8784191b523f79a357c9a1284ec Mon Sep 17 00:00:00 2001
From: Andrea Gazzarini <agazzarini@apache.org>
Date: Fri, 27 Feb 2009 13:32:19 +0000
Subject: QPID-1606 : Pausable Subscription Manager capability example.

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@748512 13f79535-47bb-0310-9956-ffa450edef68
---
 .../example/ConsumerAndProducerExample.java        |  4 +-
 .../example/PausableSubscriptionExample.java       | 88 ++++++++++++++++++++++
 2 files changed, 90 insertions(+), 2 deletions(-)
 create mode 100644 java/management/client/src/example/org/apache/qpid/management/example/PausableSubscriptionExample.java

(limited to 'java/management/client/src/example/org')

diff --git a/java/management/client/src/example/org/apache/qpid/management/example/ConsumerAndProducerExample.java b/java/management/client/src/example/org/apache/qpid/management/example/ConsumerAndProducerExample.java
index 9b4a24e2ae..42587d78ff 100644
--- a/java/management/client/src/example/org/apache/qpid/management/example/ConsumerAndProducerExample.java
+++ b/java/management/client/src/example/org/apache/qpid/management/example/ConsumerAndProducerExample.java
@@ -67,11 +67,11 @@ public class ConsumerAndProducerExample extends AbstractQManExample
 	void executeExample(String host, int port) throws Exception
 	{ 
 		// This is QMan... 
-		URI producerURI = URI.create("http://"+host+":"+port+"/qman/services/consumer");
+		URI producerURI = URI.create("http://"+host+":"+port+"/qman/services/adapter");
 		
 		// ...and this is QMan too! Note that it has an hidden consumer capability that is used in 
 		// order to run successfully this example...
-		URI consumerURI = producerURI;
+		URI consumerURI = URI.create("http://"+host+":"+port+"/qman/services/consumer");
 		
 		EndpointReference producerEPR = new EndpointReference(producerURI);		
 		EndpointReference consumerEPR = new EndpointReference(consumerURI);
diff --git a/java/management/client/src/example/org/apache/qpid/management/example/PausableSubscriptionExample.java b/java/management/client/src/example/org/apache/qpid/management/example/PausableSubscriptionExample.java
new file mode 100644
index 0000000000..01a27a16f9
--- /dev/null
+++ b/java/management/client/src/example/org/apache/qpid/management/example/PausableSubscriptionExample.java
@@ -0,0 +1,88 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you 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 org.apache.qpid.management.example;
+
+import java.net.URI;
+
+import org.apache.muse.ws.addressing.EndpointReference;
+import org.apache.muse.ws.notification.remote.NotificationProducerClient;
+import org.apache.muse.ws.notification.remote.SubscriptionClient;
+
+/**
+ * This example is demonstrating a WS-Notification scenario 
+ * when (for simplicity) QMan is at the same time consumer 
+ * and producer.
+ * 
+ * Specifically the example shows how a requestor can create, pause and resume 
+ * a subscription.
+ * 
+ * @author Andrea Gazzarini
+ *
+ */
+public class PausableSubscriptionExample extends AbstractQManExample
+{
+	@Override
+	void executeExample(String host, int port) throws Exception
+	{ 
+		// This is QMan... 
+		URI producerURI = URI.create("http://"+host+":"+port+"/qman/services/adapter");
+		
+		// ...and this is QMan too! Note that it has an hidden consumer capability that is used in 
+		// order to run successfully this example...
+		URI consumerURI = URI.create("http://"+host+":"+port+"/qman/services/consumer");
+		
+		EndpointReference producerEPR = new EndpointReference(producerURI);		
+		EndpointReference consumerEPR = new EndpointReference(consumerURI);
+	
+		NotificationProducerClient producerClient = new NotificationProducerClient(producerEPR);
+        producerClient.setTrace(true);
+
+        // 1) Creates a subscription and gets the corresponding reference.
+        SubscriptionClient subscriptionClient = producerClient.subscribe(
+        		consumerEPR,	// Consumer Endpoint reference
+        		null,			// Filter, if null that means "all messages"
+        		null);			// Termination Time : if null the subscription will never expire.
+        subscriptionClient.setTrace(true);
+        
+        
+        // 2) Pauses the subscription.
+        subscriptionClient.pauseSubscription();
+
+        // 3) Resumes the subscription.
+        subscriptionClient.resumeSubscription();
+	}	
+	
+	@Override
+	void printOutExampleDescription()
+	{
+		System.out.println("This example is demonstrating a WS-Notification scenario ");
+		System.out.println("when (for simplicity) QMan is at the same time consumer ");
+		System.out.println("and producer.");
+		System.out.println();
+		System.out.println("Specifically the example shows how a requestor can create,");
+		System.out.println("pause and resume a subscription.");
+	}
+	
+	public static void main(String[] args)
+	{
+		new PausableSubscriptionExample().execute(new String[]{"romagazzarini","8080"});
+	}
+}
-- 
cgit v1.2.1