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

[Ron Sigal]

  User: rsigal  
  Date: 06/11/28 15:31:02

  Modified:    src/tests/org/jboss/test/remoting/callback/asynch   Tag:
                        remoting_2_x AsynchCallbackTestClient.java
                        AsynchCallbackTestServer.java
  Log:
  JBREM-640:  Added test for parameter for one way invocation thread pool  max queue size.
  
  Revision  Changes    Path
  No                   revision
  
  
  No                   revision
  
  
  1.1.2.3   +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.1.2.2
  retrieving revision 1.1.2.3
  diff -u -b -r1.1.2.2 -r1.1.2.3
  --- AsynchCallbackTestClient.java	28 Nov 2006 18:44:09 -0000	1.1.2.2
  +++ AsynchCallbackTestClient.java	28 Nov 2006 20:31:02 -0000	1.1.2.3
  @@ -34,7 +34,7 @@
   
   /** 
    * @author <a href="ron.sigal at jboss.com">Ron Sigal</a>
  - * @version $Revision: 1.1.2.2 $
  + * @version $Revision: 1.1.2.3 $
    * <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();
  
  
  
  1.1.2.3   +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.1.2.2
  retrieving revision 1.1.2.3
  diff -u -b -r1.1.2.2 -r1.1.2.3
  --- AsynchCallbackTestServer.java	28 Nov 2006 18:44:09 -0000	1.1.2.2
  +++ AsynchCallbackTestServer.java	28 Nov 2006 20:31:02 -0000	1.1.2.3
  @@ -49,7 +49,7 @@
   
   /** 
    * @author <a href="ron.sigal at jboss.com">Ron Sigal</a>
  - * @version $Revision: 1.1.2.2 $
  + * @version $Revision: 1.1.2.3 $
    * <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);