[hornetq-commits] JBoss hornetq SVN: r11654 - trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/client.

[do-not-reply at jboss.org]

Author: borges
Date: 2011-11-03 09:42:27 -0400 (Thu, 03 Nov 2011)
New Revision: 11654

Modified:
   trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/client/PagingTest.java
Log:
Don't cluter std.out.

Modified: trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/client/PagingTest.java
===================================================================
--- trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/client/PagingTest.java	2011-11-03 13:42:07 UTC (rev 11653)
+++ trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/client/PagingTest.java	2011-11-03 13:42:27 UTC (rev 11654)
@@ -71,7 +71,7 @@
  * A PagingTest
  *
  * @author <a href="mailto:clebert.suconic at jboss.org">Clebert Suconic</a>
- * 
+ *
  * Created Dec 5, 2008 8:25:58 PM
  *
  *
@@ -262,7 +262,7 @@
                                PagingTest.PAGE_MAX,
                                new HashMap<String, AddressSettings>());
          server.start();
-         
+
          waitForServer(server);
 
          queue = server.locateQueue(ADDRESS);
@@ -281,7 +281,7 @@
          ClientMessage msg = consumer.receive(5000);
          if (msg != null)
          {
-            System.out.println("Msg " + msg.getIntProperty("id"));
+            // System.out.println("Msg " + msg.getIntProperty("id"));
 
             while (true)
             {
@@ -301,7 +301,7 @@
             Xid xid = xids.get(i);
             session.rollback(xid);
          }
-         System.out.println("msgCount = " + queue.getMessageCount());
+         // System.out.println("msgCount = " + queue.getMessageCount());
 
          xids.clear();
 
@@ -646,8 +646,8 @@
                                PagingTest.PAGE_MAX,
                                new HashMap<String, AddressSettings>());
          server.start();
-         
-         
+
+
          locator = createInVMNonHALocator();
          locator.setBlockOnNonDurableSend(true);
          locator.setBlockOnDurableSend(true);
@@ -661,7 +661,7 @@
          session = sf.createSession(false, false, false);
 
          producer = session.createProducer(PagingTest.ADDRESS);
-         
+
          for (int i = 0; i < numberOfMessages; i++)
          {
             message = session.createMessage(true);
@@ -678,9 +678,9 @@
                session.commit();
             }
          }
-         
+
          session.commit();
-         
+
          server.stop();
 
          server = createServer(true,
@@ -1276,13 +1276,13 @@
       {
          bb.put(getSamplebyte(j));
       }
-      
+
       final AtomicBoolean running = new AtomicBoolean(true);
-      
+
       class TCount extends Thread
       {
          Queue queue;
-         
+
          TCount(Queue queue)
          {
             this.queue = queue;
@@ -1307,11 +1307,11 @@
             }
          }
       };
-      
+
       TCount tcount1 = null;
       TCount tcount2 = null;
-      
 
+
       try
       {
          {
@@ -1337,8 +1337,8 @@
 
                session.createQueue(PagingTest.ADDRESS.toString(), PagingTest.ADDRESS + "-2", null, true);
             }
-            
-            
+
+
             ClientProducer producer = session.createProducer(PagingTest.ADDRESS);
 
             ClientMessage message = null;
@@ -1376,21 +1376,21 @@
                                PagingTest.PAGE_MAX,
                                new HashMap<String, AddressSettings>());
          server.start();
-         
+
          Queue queue1 = server.locateQueue(PagingTest.ADDRESS.concat("-1"));
-         
+
          Queue queue2 = server.locateQueue(PagingTest.ADDRESS.concat("-2"));
-         
+
          assertNotNull(queue1);
-         
+
          assertNotNull(queue2);
-         
+
          assertNotSame(queue1, queue2);
 
          tcount1 = new TCount(queue1);
-         
+
          tcount2 = new TCount(queue2);
-         
+
          tcount1.start();
          tcount2.start();
 
@@ -1500,19 +1500,19 @@
       finally
       {
          running.set(false);
-         
+
          if (tcount1 != null)
          {
             tcount1.interrupt();
             tcount1.join();
          }
-         
+
          if (tcount2 != null)
          {
             tcount2.interrupt();
             tcount2.join();
          }
-         
+
          try
          {
             server.stop();
@@ -1708,7 +1708,7 @@
    private void internaltestSendReceivePaging(final boolean persistentMessages) throws Exception
    {
 
-      System.out.println("PageDir:" + getPageDir());
+      // System.out.println("PageDir:" + getPageDir());
       clearData();
 
       Configuration config = createDefaultConfig();
@@ -1857,7 +1857,7 @@
     * - Consume the entire destination (not in page mode any more)
     * - Add stuff to a transaction again
     * - Check order
-    * 
+    *
     */
    public void testDepageDuringTransaction() throws Exception
    {
@@ -1998,9 +1998,9 @@
     * - Consume the entire destination (not in page mode any more)
     * - Add stuff to a transaction again
     * - Check order
-    * 
+    *
     *  Test under discussion at : http://community.jboss.org/thread/154061?tstart=0
-    * 
+    *
     */
    public void testDepageDuringTransaction2() throws Exception
    {
@@ -2091,9 +2091,9 @@
 
                if (msgReceived != null)
                {
-                  System.out.println("new = " + msgReceived.getBooleanProperty("new") +
-                                     " id = " +
-                                     msgReceived.getIntProperty("id"));
+//                  System.out.println("new = " + msgReceived.getBooleanProperty("new") +
+//                                     " id = " +
+//                                     msgReceived.getIntProperty("id"));
                }
 
                Assert.assertNull(msgReceived);
@@ -3838,13 +3838,13 @@
                   for (int i = 0; i < numberOfMessages; i++)
                   {
                      ClientMessage msg = cons.receive(PagingTest.RECEIVE_TIMEOUT);
-                     System.out.println("Message " + i + " consumed");
+                     // System.out.println("Message " + i + " consumed");
                      assertNotNull(msg);
                      msg.acknowledge();
 
                      if (i % 20 == 0)
                      {
-                        System.out.println("Commit consumer");
+                        // System.out.println("Commit consumer");
                         sessionConsumer.commit();
                      }
                   }
@@ -3881,7 +3881,7 @@
          {
             message = session.createMessage(persistentMessages);
 
-            System.out.println("Message " + i + " sent");
+            // System.out.println("Message " + i + " sent");
 
             HornetQBuffer bodyLocal = message.getBodyBuffer();
 
@@ -4132,7 +4132,7 @@
 
                // assertEquals(msg, message.getIntProperty("propTest").intValue());
 
-               System.out.println("i = " + i + " msg = " + message.getIntProperty("propTest"));
+               // System.out.println("i = " + i + " msg = " + message.getIntProperty("propTest"));
             }
 
             session.commit();