[jboss-cvs] JBoss Messaging SVN: r6207 - trunk/tests/src/org/jboss/messaging/tests/integration/client.

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

Author: clebert.suconic at jboss.com
Date: 2009-03-27 19:08:59 -0400 (Fri, 27 Mar 2009)
New Revision: 6207

Modified:
   trunk/tests/src/org/jboss/messaging/tests/integration/client/ConsumerWindowSizeTest.java
Log:
small tweak.. removing commit call

Modified: trunk/tests/src/org/jboss/messaging/tests/integration/client/ConsumerWindowSizeTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/client/ConsumerWindowSizeTest.java	2009-03-27 22:56:39 UTC (rev 6206)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/client/ConsumerWindowSizeTest.java	2009-03-27 23:08:59 UTC (rev 6207)
@@ -382,10 +382,18 @@
             assertEquals("A slow consumer shouldn't buffer anything on the client side!", 0, cons2.getBufferSize());
          }
 
-         session1.commit(); // just to make sure everything is flushed and no pending packets on the sending buffer, or
-         // the getMessageCount would fail
-         session2.commit();
+         session1.close(); // just to make sure everything is flushed and no pending packets on the sending buffer, or
+                           // the getMessageCount would fail
+         session2.close();
 
+         session1 = sf.createSession(false, true, true);
+         session1.start();
+         session2 = sf.createSession(false, true, true);
+         session2.start();
+         
+         prod = session1.createProducer(ADDRESS);
+
+
          assertEquals(0, getMessageCount(service, ADDRESS.toString()));
 
          // This should also work the other way around
@@ -438,10 +446,10 @@
             assertEquals("A slow consumer shouldn't buffer anything on the client side!", 0, cons1.getBufferSize());
          }
 
-         session1.commit(); // just to make sure everything is flushed and no pending packets on the sending buffer, or
-         // the getMessageCount would fail
-         session2.commit();
-
+         session1.close();
+         session1 = null;
+         session2.close();
+         session2 = null;
          assertEquals(0, getMessageCount(service, ADDRESS.toString()));
 
       }