avalon-cvs mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hamm...@apache.org
Subject cvs commit: jakarta-avalon-excalibur/altrmi/src/test/org/apache/excalibur/altrmi/test/socket CallbackEnabledCustomStreamTestCase.java
Date Wed, 05 Feb 2003 00:28:55 GMT
hammant     2003/02/04 16:28:55

  Modified:    altrmi/src/java/org/apache/excalibur/altrmi/server/impl
                        LogEnabledServerMonitor.java
               altrmi/src/test/org/apache/excalibur/altrmi/test/socket
                        CallbackEnabledCustomStreamTestCase.java
  Log:
  Start of debug of server and client monotor for callbacks.
  
  Revision  Changes    Path
  1.3       +12 -1     jakarta-avalon-excalibur/altrmi/src/java/org/apache/excalibur/altrmi/server/impl/LogEnabledServerMonitor.java
  
  Index: LogEnabledServerMonitor.java
  ===================================================================
  RCS file: /home/cvs/jakarta-avalon-excalibur/altrmi/src/java/org/apache/excalibur/altrmi/server/impl/LogEnabledServerMonitor.java,v
  retrieving revision 1.2
  retrieving revision 1.3
  diff -u -r1.2 -r1.3
  --- LogEnabledServerMonitor.java	27 Jan 2003 22:18:54 -0000	1.2
  +++ LogEnabledServerMonitor.java	5 Feb 2003 00:28:55 -0000	1.3
  @@ -11,6 +11,7 @@
   import org.apache.excalibur.altrmi.server.ServerMonitor;
   import org.apache.excalibur.altrmi.common.BadConnectionException;
   import org.apache.avalon.framework.logger.AbstractLogEnabled;
  +import org.apache.avalon.framework.logger.Logger;
   
   import java.io.IOException;
   
  @@ -23,6 +24,16 @@
    */
   public class LogEnabledServerMonitor extends AbstractLogEnabled implements ServerMonitor
   {
  +
  +    public LogEnabledServerMonitor()
  +    {
  +    }
  +
  +    public LogEnabledServerMonitor(Logger logger)
  +    {
  +        super.enableLogging(logger);
  +    }
  +
   
       public void closeError(String s, IOException e)
       {
  
  
  
  1.13      +48 -2     jakarta-avalon-excalibur/altrmi/src/test/org/apache/excalibur/altrmi/test/socket/CallbackEnabledCustomStreamTestCase.java
  
  Index: CallbackEnabledCustomStreamTestCase.java
  ===================================================================
  RCS file: /home/cvs/jakarta-avalon-excalibur/altrmi/src/test/org/apache/excalibur/altrmi/test/socket/CallbackEnabledCustomStreamTestCase.java,v
  retrieving revision 1.12
  retrieving revision 1.13
  diff -u -r1.12 -r1.13
  --- CallbackEnabledCustomStreamTestCase.java	1 Feb 2003 17:46:07 -0000	1.12
  +++ CallbackEnabledCustomStreamTestCase.java	5 Feb 2003 00:28:55 -0000	1.13
  @@ -9,6 +9,9 @@
   
   import org.apache.excalibur.altrmi.client.impl.ClientSideClassFactory;
   import org.apache.excalibur.altrmi.client.impl.callback.socket.CallbackEnabledSocketCustomStreamHostContext;
  +import org.apache.excalibur.altrmi.client.HostContext;
  +import org.apache.excalibur.altrmi.client.ConnectionListener;
  +import org.apache.excalibur.altrmi.client.ConnectionClosedException;
   
   import org.apache.excalibur.altrmi.test.TestInterface;
   import org.apache.excalibur.altrmi.test.TestInterfaceImpl;
  @@ -16,9 +19,14 @@
   import org.apache.excalibur.altrmi.test.TestInterface2;
   import org.apache.excalibur.altrmi.test.AbstractHelloCallBackTestCase;
   import org.apache.excalibur.altrmi.server.impl.callback.socket.CallbackEnabledSocketCustomStreamServer;
  +import org.apache.excalibur.altrmi.server.impl.LogEnabledServerMonitor;
   import org.apache.excalibur.altrmi.server.PublicationDescription;
  +import org.apache.excalibur.altrmi.common.Request;
  +import org.apache.excalibur.altrmi.common.InvocationException;
  +import org.apache.avalon.framework.logger.ConsoleLogger;
   
   import java.util.HashMap;
  +import java.io.IOException;
   
   
   /**
  @@ -44,12 +52,50 @@
           PublicationDescription pd = new PublicationDescription(TestInterface.class,
                   new Class[] { TestInterface3.class, TestInterface2.class });
           server.publish(testServer, "Hello", pd);
  +        server.setServerMonitor(new LogEnabledServerMonitor(new ConsoleLogger()));
           server.start();
   
           // Client side setup
           altrmiFactory = new ClientSideClassFactory();
  -        altrmiFactory.setHostContext(
  -                new CallbackEnabledSocketCustomStreamHostContext("127.0.0.1", 10004), false);
  +        HostContext hc = new CallbackEnabledSocketCustomStreamHostContext("127.0.0.1",
10004);
  +        hc.getClientInvocationHandler().setConnectionListener(new ConnectionListener()
{
  +            public void methodCalled(String methodSignature, long duration, String annotation)
  +            {
  +                System.out.println("CallbackEnabledCustomStreamTestCase.methodCalled "
+ methodSignature);
  +            }
  +
  +            public boolean methodLogging()
  +            {
  +                return true;
  +            }
  +
  +            public void serviceSuspended(Request altrmiRequest, int attempt, int suggestedWaitMillis)
  +            {
  +                System.out.println("CallbackEnabledCustomStreamTestCase.serviceSuspended");
  +            }
  +
  +            public void serviceAbend(int attempt, IOException cause)
  +            {
  +                System.out.println("CallbackEnabledCustomStreamTestCase.serviceAbend");
  +            }
  +
  +            public void invocationFailure(String name, InvocationException ie)
  +            {
  +                System.out.println("CallbackEnabledCustomStreamTestCase.invocationFailure");
  +            }
  +
  +            public void unexpectedClosedConnection(String name, ConnectionClosedException
cce)
  +            {
  +                System.out.println("CallbackEnabledCustomStreamTestCase.unexpectedClosedConnection");
  +            }
  +
  +            public void unexpectedInterruption(String name, InterruptedException ie)
  +            {
  +                System.out.println("CallbackEnabledCustomStreamTestCase.unexpectedInterruption");
  +            }
  +        });
  +        altrmiFactory.setHostContext(hc , false);
  +
           testClient = (TestInterface) altrmiFactory.lookup("Hello");
   
           // just a kludge for unit testing given we are intrinsically dealing with
  
  
  

---------------------------------------------------------------------
To unsubscribe, e-mail: avalon-cvs-unsubscribe@jakarta.apache.org
For additional commands, e-mail: avalon-cvs-help@jakarta.apache.org


Mime
View raw message