[jboss-cvs] JBoss Messaging SVN: r3844 - trunk/tests/src/org/jboss/messaging/core/remoting/ssl/integration.

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

Author: jmesnil
Date: 2008-03-04 11:54:35 -0500 (Tue, 04 Mar 2008)
New Revision: 3844

Modified:
   trunk/tests/src/org/jboss/messaging/core/remoting/ssl/integration/CoreClientOverSSL.java
   trunk/tests/src/org/jboss/messaging/core/remoting/ssl/integration/CoreClientOverSSLTest.java
Log:
* fixed calls to ClientConnection.createSession() to comply to ackBatchSize assertion

Modified: trunk/tests/src/org/jboss/messaging/core/remoting/ssl/integration/CoreClientOverSSL.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/core/remoting/ssl/integration/CoreClientOverSSL.java	2008-03-04 16:23:03 UTC (rev 3843)
+++ trunk/tests/src/org/jboss/messaging/core/remoting/ssl/integration/CoreClientOverSSL.java	2008-03-04 16:54:35 UTC (rev 3844)
@@ -82,7 +82,7 @@
          MessagingServer server = new MessagingServerImpl();
          ClientConnectionFactory cf = new ClientConnectionFactoryImpl(0, remotingConf, server.getVersion());
          ClientConnection conn = cf.createConnection(null, null);
-         ClientSession session = conn.createClientSession(false, true, true, 0, false, false);
+         ClientSession session = conn.createClientSession(false, true, true, -1, false, false);
          ClientProducer producer = session.createProducer(QUEUE);
 
          MessageImpl message = new MessageImpl(JBossTextMessage.TYPE, false, 0,

Modified: trunk/tests/src/org/jboss/messaging/core/remoting/ssl/integration/CoreClientOverSSLTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/core/remoting/ssl/integration/CoreClientOverSSLTest.java	2008-03-04 16:23:03 UTC (rev 3843)
+++ trunk/tests/src/org/jboss/messaging/core/remoting/ssl/integration/CoreClientOverSSLTest.java	2008-03-04 16:54:35 UTC (rev 3844)
@@ -130,7 +130,7 @@
 
       ClientConnectionFactory cf = new ClientConnectionFactoryImpl(0, remotingConf, server.getVersion());
       connection = cf.createConnection(null, null);
-      ClientSession session = connection.createClientSession(false, true, true, 0, false, false);
+      ClientSession session = connection.createClientSession(false, true, true, -1, false, false);
       session.createQueue(QUEUE, QUEUE, null, false, false);
       consumer = session.createConsumer(QUEUE, null, false, false, true);
       connection.start();