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

[Ron Sigal]

  User: rsigal  
  Date: 06/11/28 15:41:38

  Modified:    src/tests/org/jboss/test/remoting/callback/asynch  
                        AsynchCallbackTestServer.java
                        AsynchCallbackTestClient.java
  Log:
  JBREM-640:  Added test for parameter for one way invocation thread pool  max queue size.
  
  Revision  Changes    Path
  1.4       +20 -2     JBossRemoting/src/tests/org/jboss/test/remoting/callback/asynch/AsynchCallbackTestServer.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: AsynchCallbackTestServer.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossRemoting/src/tests/org/jboss/test/remoting/callback/asynch/AsynchCallbackTestServer.java,v
  retrieving revision 1.3
  retrieving revision 1.4
  diff -u -b -r1.3 -r1.4
  --- AsynchCallbackTestServer.java	28 Nov 2006 19:01:53 -0000	1.3
  +++ AsynchCallbackTestServer.java	28 Nov 2006 20:41:38 -0000	1.4
  @@ -49,7 +49,7 @@
   
   /** 
    * @author <a href="ron.sigal at jboss.com">Ron Sigal</a>
  - * @version $Revision: 1.3 $
  + * @version $Revision: 1.4 $
    * <p>
    * Copyright Nov 25, 2006
    * </p>
  @@ -65,7 +65,9 @@
      public static String GET_STATUS = "getStatus";
      public static String RESET = "reset";
      public static String GET_THREAD_COUNT = "getThreadCount";
  +   public static String GET_QUEUE_SIZE = "getQueueSize";
      public static String THREAD_COUNT = "17";
  +   public static String QUEUE_SIZE = "19";
      
      private static Logger log = Logger.getLogger(AsynchCallbackTestServer.class);
      
  @@ -84,7 +86,8 @@
         InvokerLocator serverLocator = new InvokerLocator(locatorURI);
         System.out.println("Starting remoting server with locator uri of: " + locatorURI);
         Map config = new HashMap();
  -      config.put(ServerInvoker.MAX_NUM_ONEWAY_THREADS_KEY, THREAD_COUNT);
  +      config.put(Client.MAX_NUM_ONEWAY_THREADS, THREAD_COUNT);
  +      config.put(Client.MAX_ONEWAY_THREAD_POOL_QUEUE_SIZE, QUEUE_SIZE);
         connector = new Connector(serverLocator, config);
         connector.create();
         SampleInvocationHandler invocationHandler = new SampleInvocationHandler();
  @@ -184,6 +187,21 @@
                  int size = threadPool.getMaximumPoolSize();
                  return Integer.toString(size);
               }
  +            else if (test.equals(GET_QUEUE_SIZE))
  +            {
  +               ServerInvoker invoker = connector.getServerInvoker();
  +               Field field = ServerInvoker.class.getDeclaredField("callbackHandlers");
  +               field.setAccessible(true);
  +               Map callbackHandlers = (Map) field.get(invoker);
  +               Iterator it = callbackHandlers.values().iterator();
  +               ServerInvokerCallbackHandler callbackHandler = (ServerInvokerCallbackHandler) it.next();
  +               Client callbackClient = callbackHandler.getCallbackClient();
  +               field = Client.class.getDeclaredField("onewayThreadPool");
  +               field.setAccessible(true);
  +               BasicThreadPool threadPool = (BasicThreadPool) field.get(callbackClient);
  +               int size = threadPool.getMaximumQueueSize();
  +               return Integer.toString(size);
  +            }
               else
               {
                  log.error("unrecognized test: " + test);
  
  
  
  1.4       +3 -1      JBossRemoting/src/tests/org/jboss/test/remoting/callback/asynch/AsynchCallbackTestClient.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: AsynchCallbackTestClient.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossRemoting/src/tests/org/jboss/test/remoting/callback/asynch/AsynchCallbackTestClient.java,v
  retrieving revision 1.3
  retrieving revision 1.4
  diff -u -b -r1.3 -r1.4
  --- AsynchCallbackTestClient.java	28 Nov 2006 19:01:53 -0000	1.3
  +++ AsynchCallbackTestClient.java	28 Nov 2006 20:41:38 -0000	1.4
  @@ -34,7 +34,7 @@
   
   /** 
    * @author <a href="ron.sigal at jboss.com">Ron Sigal</a>
  - * @version $Revision: 1.3 $
  + * @version $Revision: 1.4 $
    * <p>
    * Copyright Nov 25, 2006
    * </p>
  @@ -121,6 +121,8 @@
         assertTrue(callbackHandler.receivedCallback);
         String threadCount = (String) client.invoke(AsynchCallbackTestServer.GET_THREAD_COUNT);
         assertEquals(AsynchCallbackTestServer.THREAD_COUNT, threadCount);
  +      String queueSize = (String) client.invoke(AsynchCallbackTestServer.GET_QUEUE_SIZE);
  +      assertEquals(AsynchCallbackTestServer.QUEUE_SIZE, queueSize);
         client.invoke(AsynchCallbackTestServer.RESET);
         client.removeListener(callbackHandler);
         client.disconnect();