qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From agazzar...@apache.org
Subject svn commit: r743629 - /qpid/trunk/qpid/java/management/client/src/example/org/apache/qpid/management/example/ConsumerAndProducerExample.java
Date Thu, 12 Feb 2009 06:18:02 GMT
Author: agazzarini
Date: Thu Feb 12 06:18:02 2009
New Revision: 743629

URL: http://svn.apache.org/viewvc?rev=743629&view=rev
Log:
QPID-1606 : Added an additional example for Consumer / Producer WS-Notification scenario.

Added:
    qpid/trunk/qpid/java/management/client/src/example/org/apache/qpid/management/example/ConsumerAndProducerExample.java

Added: qpid/trunk/qpid/java/management/client/src/example/org/apache/qpid/management/example/ConsumerAndProducerExample.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/management/client/src/example/org/apache/qpid/management/example/ConsumerAndProducerExample.java?rev=743629&view=auto
==============================================================================
--- qpid/trunk/qpid/java/management/client/src/example/org/apache/qpid/management/example/ConsumerAndProducerExample.java
(added)
+++ qpid/trunk/qpid/java/management/client/src/example/org/apache/qpid/management/example/ConsumerAndProducerExample.java
Thu Feb 12 06:18:02 2009
@@ -0,0 +1,248 @@
+/*
+ *
+ * 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 java.util.Date;
+
+import org.apache.muse.util.xml.XPathUtils;
+import org.apache.muse.ws.addressing.EndpointReference;
+import org.apache.muse.ws.addressing.soap.SoapFault;
+import org.apache.muse.ws.notification.impl.MessagePatternFilter;
+import org.apache.muse.ws.notification.impl.TopicFilter;
+import org.apache.muse.ws.notification.remote.NotificationProducerClient;
+import org.apache.qpid.management.Names;
+
+/**
+ * This example is demonstrating a WS-Notification scenario 
+ * when (for simplicity) QMan is at the same time consumer 
+ * and producer.
+ * 
+ * Basically we have (on producer side) two topics : one for 
+ * lifecycle events of object instance (objects created & removed) 
+ * and another one for lifecycle of event (events created).
+ * 
+ * On consumer side there are many options that you can use in 
+ * order to made a sunscription :
+ * 
+ * <ul>
+ * 	<li>you could be an observer of all messages (all topics);</li>
+ * 	<li>you could be an observer of one specific topic;</li>
+ * 	<li>
+ * 		you could be an observer of all messages that match 
+ * 		a condition expressed in XPath;
+ *		</li>
+ * </ul>
+ * 
+ * All those options are provided with or withour a termination time. 
+ * A subscription with a termination time will have a predefined expiry 
+ * date while if there's no termination the subscription will never expire.
+ * 
+ * @author Andrea Gazzarini
+ *
+ */
+public class ConsumerAndProducerExample extends AbstractQManExample
+{
+	@Override
+	void executeExample(String host, int port) throws Exception
+	{ 
+		// This is QMan... 
+		URI producerURI = URI.create("http://"+host+":"+port+"/qman/services/consumer");
+		
+		// ...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;
+		
+		EndpointReference producerEPR = new EndpointReference(producerURI);		
+		EndpointReference consumerEPR = new EndpointReference(consumerURI);
+	
+		// Example 1 : all messages on all topics without termination time.
+        subscribeAllMessagesWithoutTerminationTime(producerEPR,consumerEPR);
+        
+		// Example 2 : all messages on all topics with termination time.
+        subscribeAllMessagesWithTerminationTime(producerEPR,consumerEPR);
+
+        // Example 3: Topic filter without termination time.
+        topicSubscriptionWithoutTerminationTime(producerEPR,consumerEPR);
+        
+        // Example 4: Topic filter with termination time.        
+        topicSubscriptionWithTerminationTime(producerEPR,consumerEPR);
+
+        // Example 5: a MessageFilter is installed in order to listen only for connection
events 
+        // (connections created or removed). The subscription never expire.
+        allMessagesWithMessageFilterWithoutTerminationTime(producerEPR,consumerEPR);
+        
+        // Example 6: a MessageFilter is installed in order to listen only for connection
events 
+        // (connections created or removed). The subscription will expire in 10 seconds.
+        allMessagesWithMessageFilterAndTerminationTime(producerEPR,consumerEPR);
+	}	
+	
+	/**
+	 * Makes a subscription on all topics / all messages without an expiry date.
+	 * 
+	 * @param producer the producer endpoint reference.
+	 * @param consumer the consumer endpoint reference .
+	 * @throws SoapFault when the subscription cannot be made.
+	 */
+	private void subscribeAllMessagesWithoutTerminationTime(EndpointReference producer, EndpointReference
consumer) throws SoapFault
+	{
+		NotificationProducerClient producerClient = new NotificationProducerClient(producer);
+        producerClient.setTrace(true);
+
+        producerClient.subscribe(
+        		consumer,	// Consumer Endpoint reference
+        		null,			// Filter, if null that means "all messages"
+        		null);			// Termination Time : if null the subscription will never expire.
+	}
+
+	/**
+	 * Makes a subscription on all topics / all messages with 10 seconds as termination time.
+	 * The subscription will expire after 10 seconds.
+	 * 
+	 * @param producer the producer endpoint reference.
+	 * @param consumer the consumer endpoint reference .
+	 * @throws SoapFault when the subscription cannot be made.
+	 */
+	private void subscribeAllMessagesWithTerminationTime(EndpointReference producer, EndpointReference
consumer) throws SoapFault
+	{
+		NotificationProducerClient producerClient = new NotificationProducerClient(producer);
+        producerClient.setTrace(true);
+
+        producerClient.subscribe(
+        		consumer,	// Consumer Endpoint reference
+        		null,			// Filter, if null that means "all messages"
+        		new Date(System.currentTimeMillis() + 10000));	// Termination Time 
+	}
+
+	/**
+	 * Makes a subscription on a specifc topic without an expiry date.
+	 * Only messages published on the given topic will be delivered to the given consumer.
+	 * 
+	 * @param producer the producer endpoint reference.
+	 * @param consumer the consumer endpoint reference .
+	 * @throws SoapFault when the subscription cannot be made.
+	 */
+	private void topicSubscriptionWithoutTerminationTime(EndpointReference producer, EndpointReference
consumer) throws SoapFault
+	{
+		NotificationProducerClient producerClient = new NotificationProducerClient(producer);
+        producerClient.setTrace(true);
+
+		TopicFilter filter = new TopicFilter(Names.EVENTS_LIFECYLE_TOPIC_NAME);
+
+        producerClient.subscribe(
+        		consumer,	// Consumer Endpoint reference
+        		filter,			// Topic Filter
+        		null);			// Termination Time : if null the subscription will never expire.
+	}
+
+	/**
+	 * Makes a subscription on a specifc topic with an expiry date.
+	 * Only messages published on the given topic will be delivered to the given consumer.
+	 * The subscription will end after 10 seconds
+	 * 
+	 * @param producer the producer endpoint reference.
+	 * @param consumer the consumer endpoint reference .
+	 * @throws SoapFault when the subscription cannot be made.
+	 */
+	private void topicSubscriptionWithTerminationTime(EndpointReference producer, EndpointReference
consumer) throws SoapFault
+	{
+		NotificationProducerClient producerClient = new NotificationProducerClient(producer);
+        producerClient.setTrace(true);
+
+		TopicFilter filter = new TopicFilter(Names.EVENTS_LIFECYLE_TOPIC_NAME);
+
+        producerClient.subscribe(
+        		consumer,	// Consumer Endpoint reference
+        		filter,			// Topic Filter
+        		new Date(System.currentTimeMillis() + 10000));	// Termination Time 
+	}
+
+	/**
+	 * Makes a subscription on all topics with a message filter without an expiry date.
+	 * 
+	 * @param producer the producer endpoint reference.
+	 * @param consumer the consumer endpoint reference .
+	 * @throws SoapFault when the subscription cannot be made.
+	 */
+	private void allMessagesWithMessageFilterWithoutTerminationTime(EndpointReference producer,
EndpointReference consumer) throws SoapFault
+	{
+		NotificationProducerClient producerClient = new NotificationProducerClient(producer);
+        producerClient.setTrace(true);
+
+        // Applying this filter will result in a subscription that wll be notified only when
a "connection" 
+        // object is created or removed
+        MessagePatternFilter filter= new MessagePatternFilter(
+        		"/wsnt:NotificationMessage/wsnt:Message/qman:LifeCycleEvent/qman:Resource/qman:Name/text()='connection'",
// expression (XPath)
+        		XPathUtils.NAMESPACE_URI); // Dialect : the only supported dialect is XPath 1.0
+        
+        producerClient.subscribe(
+        		consumer,	// Consumer Endpoint reference
+        		filter,			// Message Filter
+        		null);			// Termination Time : if null the subscription will never expire.
+	}
+	
+	/**
+	 * Makes a subscription on all topics with a message filter and an expiry date.
+	 * 
+	 * @param producer the producer endpoint reference.
+	 * @param consumer the consumer endpoint reference .
+	 * @throws SoapFault when the subscription cannot be made.
+	 */
+	private void allMessagesWithMessageFilterAndTerminationTime(EndpointReference producer,
EndpointReference consumer) throws SoapFault
+	{
+		NotificationProducerClient producerClient = new NotificationProducerClient(producer);
+        producerClient.setTrace(true);
+
+        // Applying this filter will result in a subscription that wll be notified only when
a "connection" 
+        // object is created or removed
+        MessagePatternFilter filter= new MessagePatternFilter(
+        		"/wsnt:NotificationMessage/wsnt:Message/qman:LifeCycleEvent/qman:Resource/qman:Name/text()='connection'",
// expression (XPath)
+        		XPathUtils.NAMESPACE_URI); // Dialect : the only supported dialect is XPath 1.0
+        
+        producerClient.subscribe(
+        		consumer,	// Consumer Endpoint reference
+        		filter,			// Message Filter
+        		new Date(System.currentTimeMillis() + 10000));	// Termination Time 
+	}
+	
+	@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("Basically we have (on producer side) two topics : one for"); 
+		System.out.println("lifecycle events of object instance (objects created & removed)
");
+		System.out.println("and another one for lifecycle of event (events created).");
+		System.out.println();
+		System.out.println("On consumer side there are many options that you can use in"); 
+		System.out.println("order to made a sunscription :");
+		System.out.println();
+		System.out.println("- you could be an observer of all messages (all topics);");
+		System.out.println("- you could be an observer of one specific topic;");
+		System.out.println("- you could be an observer of all messages that match a condition expressed
in XPath;");
+		System.out.println();
+		System.out.println("All those options are provided with or withour a termination time.");

+		System.out.println("A subscription with a termination time will have a predefined expiry");

+		System.out.println("date while if there's no termination the subscription will never expire.");
+	}
+}



---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org


Mime
View raw message