[jboss-cvs] JBoss Messaging SVN: r4097 - projects/network-benchmark/src/core.

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

Author: jmesnil
Date: 2008-04-22 10:39:09 -0400 (Tue, 22 Apr 2008)
New Revision: 4097

Modified:
   projects/network-benchmark/src/core/CoreMessagingClientTest.java
Log:
sending a "Hello, World" message represents 90 bytes 

Modified: projects/network-benchmark/src/core/CoreMessagingClientTest.java
===================================================================
--- projects/network-benchmark/src/core/CoreMessagingClientTest.java	2008-04-22 14:27:13 UTC (rev 4096)
+++ projects/network-benchmark/src/core/CoreMessagingClientTest.java	2008-04-22 14:39:09 UTC (rev 4097)
@@ -8,7 +8,6 @@
 import java.util.concurrent.atomic.AtomicLong;
 
 import junit.framework.TestCase;
-
 import network.CommonSetting;
 
 import org.jboss.messaging.core.client.ClientConnection;
@@ -17,7 +16,7 @@
 import org.jboss.messaging.core.client.ClientProducer;
 import org.jboss.messaging.core.client.ClientSession;
 import org.jboss.messaging.core.client.ConnectionParams;
-import org.jboss.messaging.core.client.FailureListener;
+import org.jboss.messaging.core.client.RemotingSessionListener;
 import org.jboss.messaging.core.client.Location;
 import org.jboss.messaging.core.client.MessageHandler;
 import org.jboss.messaging.core.client.impl.ClientConnectionFactoryImpl;
@@ -68,12 +67,12 @@
       ClientConnectionFactory cf = new ClientConnectionFactoryImpl(0, location, params);
 
       conn = cf.createConnection();
-      conn.setFailureListener(new FailureListener()
+      conn.setRemotingSessionListener(new RemotingSessionListener()
       {
-
-         public void onFailure(MessagingException me)
+         public void sessionDestroyed(long sessionID, MessagingException me)
          {
-            me.printStackTrace();
+            if (me != null)
+               me.printStackTrace();
          }
       });
 
@@ -128,7 +127,7 @@
 
          Message message = new MessageImpl(JBossTextMessage.TYPE, durable, 0,
                System.currentTimeMillis(), (byte) 1);
-         message.setPayload("testSendOneMessage".getBytes());
+         message.setPayload("Hello, World".getBytes());
 
          final AtomicLong receivedCountDuringWarmup = new AtomicLong(0);
          final AtomicLong receivedCountAfterWarmup = new AtomicLong(0);
@@ -167,7 +166,6 @@
             producer.send(message);
             sentCount++;
          }
-
          while ((receivedCountDuringWarmup.get() + receivedCountAfterWarmup
                .get()) < sentCount)
          {
@@ -179,8 +177,13 @@
 
          long duration = System.currentTimeMillis() - start - WARMUP;
          display(sentCount, receivedCountAfterWarmup.longValue(), duration);
-      } finally
+      } catch (Exception e)
       {
+         e.printStackTrace();
+         fail(e.getMessage());
+      }
+      finally
+      {
          if (consumer != null)
             consumer.close();