[jboss-cvs] JBossRemoting/src/tests/org/jboss/test/remoting/transport/socket/timeout/idle ...

[Tom Elrod]

  User: telrod  
  Date: 06/11/03 11:14:35

  Added:       src/tests/org/jboss/test/remoting/transport/socket/timeout/idle 
                        Tag: remoting_2_x SampleInvocationHandler.java
  Log:
  JBREM-607 - adding idle timeout for server threads
  
  Revision  Changes    Path
  No                   revision
  
  
  No                   revision
  
  
  1.1.2.1   +57 -0     JBossRemoting/src/tests/org/jboss/test/remoting/transport/socket/timeout/idle/Attic/SampleInvocationHandler.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: SampleInvocationHandler.java
  ===================================================================
  RCS file: SampleInvocationHandler.java
  diff -N SampleInvocationHandler.java
  --- /dev/null	1 Jan 1970 00:00:00 -0000
  +++ SampleInvocationHandler.java	3 Nov 2006 16:14:35 -0000	1.1.2.1
  @@ -0,0 +1,57 @@
  +package org.jboss.test.remoting.transport.socket.timeout.idle;
  +
  +import org.jboss.remoting.ServerInvocationHandler;
  +import org.jboss.remoting.InvocationRequest;
  +import org.jboss.remoting.ServerInvoker;
  +import org.jboss.remoting.callback.InvokerCallbackHandler;
  +import org.apache.log4j.Logger;
  +
  +import javax.management.MBeanServer;
  +
  +public class SampleInvocationHandler implements ServerInvocationHandler
  +{
  +   private static Logger logger = Logger.getRootLogger();
  +   private boolean first = true;
  +
  +   public Object invoke(InvocationRequest invocation) throws Throwable
  +   {
  +      Object parm = invocation.getParameter();
  +      if(parm instanceof Boolean)
  +      {
  +         synchronized(this)
  +         {
  +            if(first)
  +            {
  +               first = false;
  +               return Boolean.TRUE;
  +            }
  +            else
  +            {
  +               return Boolean.FALSE;
  +            }
  +         }
  +      }
  +      System.out.println(Thread.currentThread() + "******* Invoked " + parm);
  +      //Thread.sleep(5000);
  +      System.out.println(Thread.currentThread() + "******* Returning - response" + parm);
  +      String s = "response" + parm;
  +      return s;
  +   }
  +
  +   public void setMBeanServer(MBeanServer server)
  +   {
  +   }
  +
  +   public void setInvoker(ServerInvoker invoker)
  +   {
  +   }
  +
  +   public void addListener(InvokerCallbackHandler callbackHandler)
  +   {
  +   }
  +
  +   public void removeListener(InvokerCallbackHandler callbackHandler)
  +   {
  +   }
  +
  +}