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@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();