[jboss-cvs] JBoss Messaging SVN: r2091 - in trunk: tests/src/org/jboss/test/thirdparty/remoting and 1 other directories.

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

Author: timfox
Date: 2007-01-29 09:31:24 -0500 (Mon, 29 Jan 2007)
New Revision: 2091

Modified:
   trunk/src/etc/server/default/deploy/remoting-service.xml
   trunk/tests/src/org/jboss/test/thirdparty/remoting/SocketTransportCausalityTest.java
   trunk/tests/src/org/jboss/test/thirdparty/remoting/util/RemotingTestSubsystem.java
Log:
Some more tweaks related to http://jira.jboss.com/jira/browse/JBMESSAGING-789



Modified: trunk/src/etc/server/default/deploy/remoting-service.xml
===================================================================
--- trunk/src/etc/server/default/deploy/remoting-service.xml	2007-01-29 14:03:53 UTC (rev 2090)
+++ trunk/src/etc/server/default/deploy/remoting-service.xml	2007-01-29 14:31:24 UTC (rev 2091)
@@ -30,6 +30,7 @@
                <attribute name="NumberOfRetries">1</attribute>
                <attribute name="NumberOfCallRetries">2</attribute>
                <attribute name="callbackErrorsAllowed">1</attribute>
+               <attribute name="onewayThreadPool">org.jboss.jms.server.remoting.DirectThreadPool</attribute>
             </invoker>
             <handlers>
                <handler subsystem="JMS">org.jboss.jms.server.remoting.JMSServerInvocationHandler</handler>

Modified: trunk/tests/src/org/jboss/test/thirdparty/remoting/SocketTransportCausalityTest.java
===================================================================
--- trunk/tests/src/org/jboss/test/thirdparty/remoting/SocketTransportCausalityTest.java	2007-01-29 14:03:53 UTC (rev 2090)
+++ trunk/tests/src/org/jboss/test/thirdparty/remoting/SocketTransportCausalityTest.java	2007-01-29 14:31:24 UTC (rev 2091)
@@ -99,6 +99,9 @@
             }
          }
          
+         //Let invocations finish
+         Thread.sleep(5000);
+         
          boolean failed = 
             RemotingTestSubsystemService.isFailed(subsystemService);
          
@@ -153,6 +156,8 @@
                inv.num = ++num;
                
                client.invokeOneway(inv);
+               
+               log.trace("client " + clientNumber + " sent " + num);
             }
          }
          catch (Throwable t)
@@ -194,11 +199,7 @@
       String s = (String)ServerManagement.
          getAttribute(ServiceContainer.REMOTING_OBJECT_NAME, "InvokerLocator");
       
-      //Hmmm adding this doesn't seem to make any difference to what thread pool
-      //is used on the server side......
-      s += "&onewayThreadPool=org.jboss.jms.server.remoting.DirectThreadPool";
-
-      log.info("Locator is " + s);
+      log.trace("Locator is " + s);
       
       serverLocator = new InvokerLocator(s);
       

Modified: trunk/tests/src/org/jboss/test/thirdparty/remoting/util/RemotingTestSubsystem.java
===================================================================
--- trunk/tests/src/org/jboss/test/thirdparty/remoting/util/RemotingTestSubsystem.java	2007-01-29 14:03:53 UTC (rev 2090)
+++ trunk/tests/src/org/jboss/test/thirdparty/remoting/util/RemotingTestSubsystem.java	2007-01-29 14:31:24 UTC (rev 2091)
@@ -106,17 +106,15 @@
             
             int lastCount = this.counters[clientNum];
             
+            log.trace("Received client " + clientNum + " num " + inv.num);
+            
             if (inv.num != lastCount + 1)
             {
                //Failed - out of sequence
                failed = true;
                
-               log.info("Failed!!!! out of sequence");
+               log.trace("Failed!!!! out of sequence");
             }
-            else
-            {
-               log.info("Ok");
-            }
             
             counters[clientNum] = inv.num;