[jboss-cvs] JBoss Messaging SVN: r4169 - trunk/tests/jms-tests/src/org/jboss/test/messaging/jms.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Fri May 9 08:52:40 EDT 2008
Author: timfox
Date: 2008-05-09 08:52:40 -0400 (Fri, 09 May 2008)
New Revision: 4169
Modified:
trunk/tests/jms-tests/src/org/jboss/test/messaging/jms/MessageProducerTest.java
Log:
Commented out temp test
Modified: trunk/tests/jms-tests/src/org/jboss/test/messaging/jms/MessageProducerTest.java
===================================================================
--- trunk/tests/jms-tests/src/org/jboss/test/messaging/jms/MessageProducerTest.java 2008-05-09 12:39:52 UTC (rev 4168)
+++ trunk/tests/jms-tests/src/org/jboss/test/messaging/jms/MessageProducerTest.java 2008-05-09 12:52:40 UTC (rev 4169)
@@ -152,190 +152,190 @@
}
}
}
-
- public void testSpeed() throws Exception
- {
- Connection pconn = null;
-
- try
- {
- pconn = cf.createConnection();
-
- Session ps = pconn.createSession(false, Session.DUPS_OK_ACKNOWLEDGE);
-
- MessageProducer p = ps.createProducer(queue1);
-
- pconn.start();
-
- p.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
-
- p.setDisableMessageID(true);
- p.setDisableMessageTimestamp(true);
-
- final int numMessages = 100000;
-
- long start = System.currentTimeMillis();
-
- BytesMessage msg = ps.createBytesMessage();
-
- msg.writeBytes(new byte[200]);
-
- for (int i = 0; i < numMessages; i++)
- {
- p.send(msg);
- }
-
- long end = System.currentTimeMillis();
-
- double actualRate = 1000 * (double)numMessages / ( end - start);
-
- log.info("rate " + actualRate + " msgs /sec");
-
- }
- finally
- {
- pconn.close();
- }
- }
+//
+// public void testSpeed() throws Exception
+// {
+// Connection pconn = null;
+//
+// try
+// {
+// pconn = cf.createConnection();
+//
+// Session ps = pconn.createSession(false, Session.DUPS_OK_ACKNOWLEDGE);
+//
+// MessageProducer p = ps.createProducer(queue1);
+//
+// pconn.start();
+//
+// p.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
+//
+// p.setDisableMessageID(true);
+// p.setDisableMessageTimestamp(true);
+//
+// final int numMessages = 100000;
+//
+// long start = System.currentTimeMillis();
+//
+// BytesMessage msg = ps.createBytesMessage();
+//
+// msg.writeBytes(new byte[200]);
+//
+// for (int i = 0; i < numMessages; i++)
+// {
+// p.send(msg);
+// }
+//
+// long end = System.currentTimeMillis();
+//
+// double actualRate = 1000 * (double)numMessages / ( end - start);
+//
+// log.info("rate " + actualRate + " msgs /sec");
+//
+// }
+// finally
+// {
+// pconn.close();
+// }
+// }
+//
+// public void testSpeed2() throws Exception
+// {
+// Connection pconn = null;
+//
+// try
+// {
+// pconn = cf.createConnection();
+//
+// Session ps = pconn.createSession(false, Session.DUPS_OK_ACKNOWLEDGE);
+//
+// MessageProducer p = ps.createProducer(queue1);
+//
+// MessageConsumer cons = ps.createConsumer(queue1);
+//
+// pconn.start();
+//
+// p.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
+//
+// p.setDisableMessageID(true);
+// p.setDisableMessageTimestamp(true);
+//
+// final int numMessages = 100000;
+//
+// long start = System.currentTimeMillis();
+//
+// BytesMessage msg = ps.createBytesMessage();
+//
+// msg.writeBytes(new byte[1000]);
+//
+// final CountDownLatch latch = new CountDownLatch(1);
+//
+// class MyListener implements MessageListener
+// {
+// int count;
+//
+// public void onMessage(Message msg)
+// {
+// count++;
+//
+// if (count == numMessages)
+// {
+// latch.countDown();
+// }
+// }
+// }
+//
+// cons.setMessageListener(new MyListener());
+//
+// for (int i = 0; i < numMessages; i++)
+// {
+// p.send(msg);
+// }
+//
+// latch.await();
+//
+// long end = System.currentTimeMillis();
+//
+// double actualRate = 1000 * (double)numMessages / ( end - start);
+//
+// log.info("rate " + actualRate + " msgs /sec");
+//
+// }
+// finally
+// {
+// pconn.close();
+// }
+// }
+//
+// public void testSpeed3() throws Exception
+// {
+// Connection pconn = null;
+//
+// try
+// {
+// pconn = cf.createConnection();
+//
+// Session ps = pconn.createSession(false, Session.DUPS_OK_ACKNOWLEDGE);
+//
+// MessageProducer p = ps.createProducer(queue1);
+//
+// MessageConsumer cons = ps.createConsumer(queue1);
+//
+// p.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
+//
+// p.setDisableMessageID(true);
+// p.setDisableMessageTimestamp(true);
+//
+// final int numMessages = 100000;
+//
+// BytesMessage msg = ps.createBytesMessage();
+//
+// msg.writeBytes(new byte[1000]);
+//
+// final CountDownLatch latch = new CountDownLatch(1);
+//
+// class MyListener implements MessageListener
+// {
+// int count;
+//
+// public void onMessage(Message msg)
+// {
+// count++;
+//
+// if (count == numMessages)
+// {
+// latch.countDown();
+// }
+// }
+// }
+//
+// cons.setMessageListener(new MyListener());
+//
+// for (int i = 0; i < numMessages; i++)
+// {
+// p.send(msg);
+// }
+//
+// long start = System.currentTimeMillis();
+//
+//
+// pconn.start();
+//
+//
+// latch.await();
+//
+// long end = System.currentTimeMillis();
+//
+// double actualRate = 1000 * (double)numMessages / ( end - start);
+//
+// log.info("rate " + actualRate + " msgs /sec");
+//
+// }
+// finally
+// {
+// pconn.close();
+// }
+// }
- public void testSpeed2() throws Exception
- {
- Connection pconn = null;
-
- try
- {
- pconn = cf.createConnection();
-
- Session ps = pconn.createSession(false, Session.DUPS_OK_ACKNOWLEDGE);
-
- MessageProducer p = ps.createProducer(queue1);
-
- MessageConsumer cons = ps.createConsumer(queue1);
-
- pconn.start();
-
- p.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
-
- p.setDisableMessageID(true);
- p.setDisableMessageTimestamp(true);
-
- final int numMessages = 100000;
-
- long start = System.currentTimeMillis();
-
- BytesMessage msg = ps.createBytesMessage();
-
- msg.writeBytes(new byte[1000]);
-
- final CountDownLatch latch = new CountDownLatch(1);
-
- class MyListener implements MessageListener
- {
- int count;
-
- public void onMessage(Message msg)
- {
- count++;
-
- if (count == numMessages)
- {
- latch.countDown();
- }
- }
- }
-
- cons.setMessageListener(new MyListener());
-
- for (int i = 0; i < numMessages; i++)
- {
- p.send(msg);
- }
-
- latch.await();
-
- long end = System.currentTimeMillis();
-
- double actualRate = 1000 * (double)numMessages / ( end - start);
-
- log.info("rate " + actualRate + " msgs /sec");
-
- }
- finally
- {
- pconn.close();
- }
- }
-
- public void testSpeed3() throws Exception
- {
- Connection pconn = null;
-
- try
- {
- pconn = cf.createConnection();
-
- Session ps = pconn.createSession(false, Session.DUPS_OK_ACKNOWLEDGE);
-
- MessageProducer p = ps.createProducer(queue1);
-
- MessageConsumer cons = ps.createConsumer(queue1);
-
- p.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
-
- p.setDisableMessageID(true);
- p.setDisableMessageTimestamp(true);
-
- final int numMessages = 100000;
-
- BytesMessage msg = ps.createBytesMessage();
-
- msg.writeBytes(new byte[1000]);
-
- final CountDownLatch latch = new CountDownLatch(1);
-
- class MyListener implements MessageListener
- {
- int count;
-
- public void onMessage(Message msg)
- {
- count++;
-
- if (count == numMessages)
- {
- latch.countDown();
- }
- }
- }
-
- cons.setMessageListener(new MyListener());
-
- for (int i = 0; i < numMessages; i++)
- {
- p.send(msg);
- }
-
- long start = System.currentTimeMillis();
-
-
- pconn.start();
-
-
- latch.await();
-
- long end = System.currentTimeMillis();
-
- double actualRate = 1000 * (double)numMessages / ( end - start);
-
- log.info("rate " + actualRate + " msgs /sec");
-
- }
- finally
- {
- pconn.close();
- }
- }
-
public void testTransactedSendPersistent() throws Exception
{
transactedSend(true);
More information about the jboss-cvs-commits
mailing list