[jboss-cvs] JBoss Messaging SVN: r5447 - trunk/examples/messaging/src/org/jboss/messaging/example.

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

Author: jmesnil
Date: 2008-12-02 04:51:36 -0500 (Tue, 02 Dec 2008)
New Revision: 5447

Modified:
   trunk/examples/messaging/src/org/jboss/messaging/example/ManagementClient.java
   trunk/examples/messaging/src/org/jboss/messaging/example/SSLClient.java
   trunk/examples/messaging/src/org/jboss/messaging/example/ScheduledMessageExample.java
   trunk/examples/messaging/src/org/jboss/messaging/example/SimpleClient.java
   trunk/examples/messaging/src/org/jboss/messaging/example/SimpleExample.java
   trunk/examples/messaging/src/org/jboss/messaging/example/WildCardClient.java
Log:
removed references to JBossTextMessage class (which is not available from jbm-core-client.jar)

Modified: trunk/examples/messaging/src/org/jboss/messaging/example/ManagementClient.java
===================================================================
--- trunk/examples/messaging/src/org/jboss/messaging/example/ManagementClient.java	2008-12-02 09:17:57 UTC (rev 5446)
+++ trunk/examples/messaging/src/org/jboss/messaging/example/ManagementClient.java	2008-12-02 09:51:36 UTC (rev 5447)
@@ -37,7 +37,6 @@
 import org.jboss.messaging.core.config.TransportConfiguration;
 import org.jboss.messaging.core.exception.MessagingException;
 import org.jboss.messaging.core.management.impl.ManagementServiceImpl;
-import org.jboss.messaging.jms.client.JBossTextMessage;
 import org.jboss.messaging.util.SimpleString;
 
 /*
@@ -200,11 +199,7 @@
    private static void sendMessages(final ClientSession clientSession, final SimpleString queue) throws MessagingException
    {
       ClientProducer clientProducer = clientSession.createProducer(queue);
-      ClientMessage message = clientSession.createClientMessage(JBossTextMessage.TYPE,
-                                                                false,
-                                                                0,
-                                                                System.currentTimeMillis(),
-                                                                (byte)1);
+      ClientMessage message = clientSession.createClientMessage(false);
       message.getBody().putString("Hello, World!");
       clientProducer.send(message);
       clientProducer.send(message);

Modified: trunk/examples/messaging/src/org/jboss/messaging/example/SSLClient.java
===================================================================
--- trunk/examples/messaging/src/org/jboss/messaging/example/SSLClient.java	2008-12-02 09:17:57 UTC (rev 5446)
+++ trunk/examples/messaging/src/org/jboss/messaging/example/SSLClient.java	2008-12-02 09:51:36 UTC (rev 5447)
@@ -30,7 +30,6 @@
 import org.jboss.messaging.core.config.TransportConfiguration;
 import org.jboss.messaging.core.exception.MessagingException;
 import org.jboss.messaging.integration.transports.netty.TransportConstants;
-import org.jboss.messaging.jms.client.JBossTextMessage;
 import org.jboss.messaging.util.SimpleString;
 
 /**
@@ -51,8 +50,7 @@
          clientSession = sessionFactory.createSession(false, true, true);
          SimpleString queue = new SimpleString("queuejms.testQueue");
          ClientProducer clientProducer = clientSession.createProducer(queue);
-         ClientMessage message = clientSession.createClientMessage(JBossTextMessage.TYPE, false, 0,
-               System.currentTimeMillis(), (byte) 1);
+         ClientMessage message = clientSession.createClientMessage(false);
          message.getBody().putString("Hello!");
          clientProducer.send(message);
          ClientConsumer clientConsumer = clientSession.createConsumer(queue);

Modified: trunk/examples/messaging/src/org/jboss/messaging/example/ScheduledMessageExample.java
===================================================================
--- trunk/examples/messaging/src/org/jboss/messaging/example/ScheduledMessageExample.java	2008-12-02 09:17:57 UTC (rev 5446)
+++ trunk/examples/messaging/src/org/jboss/messaging/example/ScheduledMessageExample.java	2008-12-02 09:51:36 UTC (rev 5447)
@@ -35,7 +35,6 @@
 import org.jboss.messaging.core.exception.MessagingException;
 import org.jboss.messaging.core.logging.Logger;
 import org.jboss.messaging.core.message.impl.MessageImpl;
-import org.jboss.messaging.jms.client.JBossTextMessage;
 import org.jboss.messaging.util.SimpleString;
 
 /**
@@ -55,8 +54,7 @@
          clientSession = sessionFactory.createSession(false, true, true);
          SimpleString queue = new SimpleString("queuejms.testQueue");
          ClientProducer clientProducer = clientSession.createProducer(queue);
-         ClientMessage message = clientSession.createClientMessage(JBossTextMessage.TYPE, false, 0,
-                                                       System.currentTimeMillis(), (byte) 1);
+         ClientMessage message = clientSession.createClientMessage(false);
          message.getBody().putString("Hello!");
          Calendar cal = Calendar.getInstance();
          log.info("current time " + df.format(cal.getTime()));

Modified: trunk/examples/messaging/src/org/jboss/messaging/example/SimpleClient.java
===================================================================
--- trunk/examples/messaging/src/org/jboss/messaging/example/SimpleClient.java	2008-12-02 09:17:57 UTC (rev 5446)
+++ trunk/examples/messaging/src/org/jboss/messaging/example/SimpleClient.java	2008-12-02 09:51:36 UTC (rev 5447)
@@ -29,7 +29,6 @@
 import org.jboss.messaging.core.client.impl.ClientSessionFactoryImpl;
 import org.jboss.messaging.core.config.TransportConfiguration;
 import org.jboss.messaging.core.exception.MessagingException;
-import org.jboss.messaging.jms.client.JBossTextMessage;
 import org.jboss.messaging.util.SimpleString;
 
 /**
@@ -49,8 +48,7 @@
          clientSession = sessionFactory.createSession(false, true, true);
          SimpleString queue = new SimpleString("queuejms.testQueue");
          ClientProducer clientProducer = clientSession.createProducer(queue);
-         ClientMessage message = clientSession.createClientMessage(JBossTextMessage.TYPE, false, 0,
-                                                       System.currentTimeMillis(), (byte) 1);
+         ClientMessage message = clientSession.createClientMessage(false);
          message.getBody().putString("Hello!");
          clientProducer.send(message);
          ClientConsumer clientConsumer = clientSession.createConsumer(queue);

Modified: trunk/examples/messaging/src/org/jboss/messaging/example/SimpleExample.java
===================================================================
--- trunk/examples/messaging/src/org/jboss/messaging/example/SimpleExample.java	2008-12-02 09:17:57 UTC (rev 5446)
+++ trunk/examples/messaging/src/org/jboss/messaging/example/SimpleExample.java	2008-12-02 09:51:36 UTC (rev 5447)
@@ -32,7 +32,6 @@
 import org.jboss.messaging.core.exception.MessagingException;
 import org.jboss.messaging.core.server.MessagingService;
 import org.jboss.messaging.core.server.impl.MessagingServiceImpl;
-import org.jboss.messaging.jms.client.JBossTextMessage;
 import org.jboss.messaging.util.SimpleString;
 
 /**
@@ -63,8 +62,7 @@
          SimpleString atestq = new SimpleString("atestq");
          clientSession.createQueue(atestq, atestq, null, false, true, true);
          ClientProducer clientProducer = clientSession.createProducer(atestq);
-         ClientMessage message = clientSession.createClientMessage(JBossTextMessage.TYPE, false, 0,
-                 System.currentTimeMillis(), (byte) 1);
+         ClientMessage message = clientSession.createClientMessage(false);
          message.getBody().putString("Hello!");
          clientProducer.send(message);
          ClientConsumer clientConsumer = clientSession.createConsumer(atestq);

Modified: trunk/examples/messaging/src/org/jboss/messaging/example/WildCardClient.java
===================================================================
--- trunk/examples/messaging/src/org/jboss/messaging/example/WildCardClient.java	2008-12-02 09:17:57 UTC (rev 5446)
+++ trunk/examples/messaging/src/org/jboss/messaging/example/WildCardClient.java	2008-12-02 09:51:36 UTC (rev 5447)
@@ -30,7 +30,6 @@
 import org.jboss.messaging.core.config.TransportConfiguration;
 import org.jboss.messaging.core.exception.MessagingException;
 import org.jboss.messaging.core.logging.Logger;
-import org.jboss.messaging.jms.client.JBossTextMessage;
 import org.jboss.messaging.util.SimpleString;
 
 /**
@@ -54,17 +53,9 @@
 
          ClientProducer clientProducer = clientSession.createProducer(queue);
          ClientProducer clientProducer2 = clientSession.createProducer(queue2);
-         ClientMessage message = clientSession.createClientMessage(JBossTextMessage.TYPE,
-                                                                   false,
-                                                                   0,
-                                                                   System.currentTimeMillis(),
-                                                                   (byte)1);
+         ClientMessage message = clientSession.createClientMessage(false);
          message.getBody().putString("This is a message from queue " + queue);
-         ClientMessage message2 = clientSession.createClientMessage(JBossTextMessage.TYPE,
-                                                                    false,
-                                                                    0,
-                                                                    System.currentTimeMillis(),
-                                                                    (byte)1);
+         ClientMessage message2 = clientSession.createClientMessage(false);
          message2.getBody().putString("This is a message from queue " + queue2);
 
          clientSession.createQueue(wildCardQ, wildCardQ, null, false, true, true);