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

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

Author: ataylor
Date: 2008-04-21 05:09:39 -0400 (Mon, 21 Apr 2008)
New Revision: 4087

Modified:
   trunk/docs/examples/jms/src/org/jboss/jms/example/QueueExample.java
Log:
fixed simple core client example

Modified: trunk/docs/examples/jms/src/org/jboss/jms/example/QueueExample.java
===================================================================
--- trunk/docs/examples/jms/src/org/jboss/jms/example/QueueExample.java	2008-04-21 09:05:26 UTC (rev 4086)
+++ trunk/docs/examples/jms/src/org/jboss/jms/example/QueueExample.java	2008-04-21 09:09:39 UTC (rev 4087)
@@ -26,11 +26,10 @@
 import javax.jms.*;
 import java.util.ResourceBundle;
 import java.util.Properties;
-import java.io.IOException;
 
 /**
  * A simple JMS Queue example that creates a producer and consumer on a queue and sends a message.
- * 
+ *
  * @author <a href="ataylor at redhat.com">Andy Taylor</a>
  */
 public class QueueExample
@@ -47,47 +46,12 @@
          connection = cf.createConnection();
          Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
          MessageProducer producer = session.createProducer(queue);
-
-
-         MessageConsumer messageConsumer = session.createConsumer(queue, "MYHEADER='one'");
-         messageConsumer.setMessageListener(new MessageListener()
-         {
-            public void onMessage(Message message)
-            {
-               System.out.println("ml1");
-            }
-         });
-
-         MessageConsumer messageConsumer2 = session.createConsumer(queue,"MYHEADER='two'");
-         messageConsumer2.setMessageListener(new MessageListener()
-         {
-            public void onMessage(Message message)
-            {
-               System.out.println("ml2");
-            }
-         });
-         for(int i = 0; i < 10; i++)
-         {
-            Message message = session.createTextMessage("This is a text message " + i);
-            if(i == 0 || i==2 || i==4 || i==6 || i==8 )
-            {
-               message.setStringProperty("MYHEADER", "one");
-            }
-            else
-            {
-               message.setStringProperty("MYHEADER", "two");
-            }
-            producer.send(message);
-         }
+         Message message = session.createTextMessage("This is a text message!");
+         producer.send(message);
+         MessageConsumer messageConsumer = session.createConsumer(queue);
          connection.start();
-         try
-         {
-            System.in.read();
-         }
-         catch (IOException e)
-         {
-            e.printStackTrace();
-         }
+         TextMessage message2 = (TextMessage) messageConsumer.receive(5000);
+         System.out.println("message = " + message2.getText());
       }
       catch (NamingException e)
       {