[jboss-remoting-commits] JBoss Remoting SVN: r4742 - remoting2/branches/2.x/src/tests/org/jboss/test/remoting/connection.

[jboss-remoting-commits at lists.jboss.org]

Author: ron.sigal at jboss.com
Date: 2008-11-28 20:17:42 -0500 (Fri, 28 Nov 2008)
New Revision: 4742

Modified:
   remoting2/branches/2.x/src/tests/org/jboss/test/remoting/connection/ConnectionValidatorConfigTestClient.java
Log:
JBREM-1069: Added testSetPingPeriodByClientConfigUsingSingleArgMethod().

Modified: remoting2/branches/2.x/src/tests/org/jboss/test/remoting/connection/ConnectionValidatorConfigTestClient.java
===================================================================
--- remoting2/branches/2.x/src/tests/org/jboss/test/remoting/connection/ConnectionValidatorConfigTestClient.java	2008-11-29 01:16:55 UTC (rev 4741)
+++ remoting2/branches/2.x/src/tests/org/jboss/test/remoting/connection/ConnectionValidatorConfigTestClient.java	2008-11-29 01:17:42 UTC (rev 4742)
@@ -181,6 +181,59 @@
    
    /**
     * Verifies that pingPeriod is set correctly if it appears in Client
+    * configuration map but Client.addConnectionListener(ConnectionListener listener)
+    * puts default value in metadata map.
+    */
+   public void testSetPingPeriodByClientConfigUsingSingleArgMethod() throws Throwable
+   {
+      log.info("entering " + getName());
+      
+      // Create client.
+      HashMap clientConfig = new HashMap();
+      addExtraClientConfig(clientConfig);
+      clientConfig.put(ConnectionValidator.VALIDATOR_PING_PERIOD, "3468");
+      Client client = new Client(serverLocator, clientConfig);
+      client.connect();
+      log.info("client is connected");
+      
+      // Test connection.
+      assertEquals("abc", client.invoke("abc"));
+      
+      // Add connection listener.
+      ConnectionListener listener = new TestConnectionListener();
+      client.addConnectionListener(listener);
+      
+      // Test pingPeriod.
+      Field field = Client.class.getDeclaredField("connectionValidator");
+      field.setAccessible(true);
+      ConnectionValidator validator = (ConnectionValidator) field.get(client);
+      field = ConnectionValidator.class.getDeclaredField("pingPeriod");
+      field.setAccessible(true);
+      long pingPeriod = ((Long) field.get(validator)).longValue();
+      assertEquals(3468, pingPeriod);
+      
+      // Test timeout.
+      field = ConnectionValidator.class.getDeclaredField("clientInvoker");
+      field.setAccessible(true);
+      AbstractInvoker invoker = (AbstractInvoker) field.get(validator);
+      field = AbstractInvoker.class.getDeclaredField("configuration");
+      field.setAccessible(true);
+      Map config = (Map) field.get(invoker);
+      Object o = config.get(ServerInvoker.TIMEOUT);
+      assertEquals(ConnectionValidator.DEFAULT_PING_TIMEOUT, o);
+      
+      // Test ping retries.
+      assertTrue(invoker instanceof MicroSocketClientInvoker);
+      MicroSocketClientInvoker socketInvoker = (MicroSocketClientInvoker) invoker;
+      int defaultPingRetries = Integer.parseInt(ConnectionValidator.DEFAULT_NUMBER_OF_PING_RETRIES);
+      assertEquals(defaultPingRetries, socketInvoker.getNumberOfCallRetries());
+         
+      client.disconnect();
+   }
+  
+   
+   /**
+    * Verifies that pingPeriod is set correctly if it appears in Client
     * configuration map.
     */
    public void testSetPingPeriodByClientConfig() throws Throwable
@@ -230,8 +283,8 @@
          
       client.disconnect();
    }
-  
    
+   
    /**
     * Verifies that pingPeriod is set correctly if a call is made to
     * Client.addConnectionListener(ConnectionListener listener, Map metadata).