[jboss-cvs] JBoss Messaging SVN: r6216 - trunk/examples/jms/queue/src/org/jboss/jms/example.

[jboss-cvs-commits at lists.jboss.org]

Author: ataylor
Date: 2009-03-30 10:56:10 -0400 (Mon, 30 Mar 2009)
New Revision: 6216

Added:
   trunk/examples/jms/queue/src/org/jboss/jms/example/QueueExample.java
Log:
new example structure

Copied: trunk/examples/jms/queue/src/org/jboss/jms/example/QueueExample.java (from rev 6208, trunk/examples/jms/src/org/jboss/jms/example/QueueExample.java)
===================================================================
--- trunk/examples/jms/queue/src/org/jboss/jms/example/QueueExample.java	                        (rev 0)
+++ trunk/examples/jms/queue/src/org/jboss/jms/example/QueueExample.java	2009-03-30 14:56:10 UTC (rev 6216)
@@ -0,0 +1,91 @@
+/*
+   * JBoss, Home of Professional Open Source
+   * Copyright 2005-2008, Red Hat Middleware LLC, and individual contributors
+   * by the @authors tag. See the copyright.txt in the distribution for a
+   * full listing of individual contributors.
+   *
+   * This is free software; you can redistribute it and/or modify it
+   * under the terms of the GNU Lesser General Public License as
+   * published by the Free Software Foundation; either version 2.1 of
+   * the License, or (at your option) any later version.
+   *
+   * This software is distributed in the hope that it will be useful,
+   * but WITHOUT ANY WARRANTY; without even the implied warranty of
+   * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+   * Lesser General Public License for more details.
+   *
+   * You should have received a copy of the GNU Lesser General Public
+   * License along with this software; if not, write to the Free
+   * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+   * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+   */
+package org.jboss.jms.example;
+
+import javax.jms.Connection;
+import javax.jms.ConnectionFactory;
+import javax.jms.JMSException;
+import javax.jms.Message;
+import javax.jms.MessageConsumer;
+import javax.jms.MessageProducer;
+import javax.jms.Queue;
+import javax.jms.Session;
+import javax.jms.TextMessage;
+import javax.naming.InitialContext;
+
+/**
+ * A simple JMS Queue example that creates a producer and consumer on a queue and sends then receives a message.
+ *
+ * @author <a href="ataylor at redhat.com">Andy Taylor</a>
+ */
+public class QueueExample extends JMSExample
+{
+   public static void main(String[] args)
+   {
+      new QueueExample().run(args);
+   }
+
+   public void runExample()
+   {
+      Connection connection = null;
+      try
+      {
+         //create an initial context, env will be picked up from client-jndi.properties
+         InitialContext initialContext = getContext();
+         Queue queue = (Queue) initialContext.lookup("/queue/exampleQueue");
+         ConnectionFactory cf = (ConnectionFactory) initialContext.lookup("/ConnectionFactory");
+         
+         connection = cf.createConnection();
+         Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+         MessageProducer producer = session.createProducer(queue);
+         Message message = session.createTextMessage("This is a text message!");
+         
+         log.info("sending message to queue");
+         producer.send(message);
+         
+         MessageConsumer messageConsumer = session.createConsumer(queue);
+         connection.start();
+         TextMessage message2 = (TextMessage) messageConsumer.receive(5000);
+         log.info("message received from queue");
+         log.info("message = " + message2.getText());
+      }
+      catch (Exception e)
+      {
+         e.printStackTrace();
+      }
+      finally
+      {
+         if(connection != null)
+         {
+            try
+            {
+               connection.close();
+            }
+            catch (JMSException e)
+            {
+               e.printStackTrace();
+            }
+         }
+      }
+   }
+
+}