[jboss-cvs] JBossRemoting/src/tests/org/jboss/test/remoting/oneway ...

[Tom Elrod]

  User: telrod  
  Date: 06/09/25 22:27:52

  Modified:    src/tests/org/jboss/test/remoting/oneway 
                        OnewayInvokerServer.java
  Log:
  JBREM-548 & JBREM-604 & JBREM-596 - updated so oneway invocations will only send data on client (and not wait for response) and only receive data on the server (and not write out response).  Also allowing socket server invoker to receive raw data from any client and send along to the handler.  Finally, fixed some issues where test cases were failing due to change leasing (JBREM-596) as well as changes made to http server invoker to work with messaging.
  
  Revision  Changes    Path
  1.7       +22 -4     JBossRemoting/src/tests/org/jboss/test/remoting/oneway/OnewayInvokerServer.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: OnewayInvokerServer.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossRemoting/src/tests/org/jboss/test/remoting/oneway/OnewayInvokerServer.java,v
  retrieving revision 1.6
  retrieving revision 1.7
  diff -u -b -r1.6 -r1.7
  --- OnewayInvokerServer.java	30 Dec 2005 05:26:44 -0000	1.6
  +++ OnewayInvokerServer.java	26 Sep 2006 02:27:52 -0000	1.7
  @@ -22,9 +22,6 @@
   
   package org.jboss.test.remoting.oneway;
   
  -import java.util.Iterator;
  -import java.util.Map;
  -import java.util.Set;
   import org.jboss.jrunit.extensions.ServerTestCase;
   import org.jboss.logging.Logger;
   import org.jboss.remoting.InvokerLocator;
  @@ -32,9 +29,13 @@
   import org.jboss.remoting.transport.Connector;
   import org.jboss.test.remoting.TestUtil;
   
  +import java.util.Iterator;
  +import java.util.Map;
  +import java.util.Set;
  +
   /**
    * @author <a href="mailto:telrod at vocalocity.net">Tom Elrod</a>
  - * @version $Revision: 1.6 $
  + * @version $Revision: 1.7 $
    */
   public class OnewayInvokerServer extends ServerTestCase //implements ShutdownListener
   {
  @@ -111,5 +112,22 @@
         }
      }
   
  +   public static void main(String[] args)
  +   {
  +      OnewayInvokerServer server = new OnewayInvokerServer();
  +      try
  +      {
  +         server.setUp();
  +
  +         Thread.currentThread().sleep(4000000);
  +
  +         server.tearDown();
  +      }
  +      catch (Exception e)
  +      {
  +         e.printStackTrace();
  +      }
  +   }
  +
   
   }