[jboss-remoting-commits] JBoss Remoting SVN: r4036 - 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-04-22 03:14:18 -0400 (Tue, 22 Apr 2008)
New Revision: 4036

Added:
   remoting2/branches/2.x/src/tests/org/jboss/test/remoting/connection/ConnectionValidatorRemoteClient.java
Log:
JBREM-947: Used for manual check on ConnectionValidator when network cable is unplugged.

Added: remoting2/branches/2.x/src/tests/org/jboss/test/remoting/connection/ConnectionValidatorRemoteClient.java
===================================================================
--- remoting2/branches/2.x/src/tests/org/jboss/test/remoting/connection/ConnectionValidatorRemoteClient.java	                        (rev 0)
+++ remoting2/branches/2.x/src/tests/org/jboss/test/remoting/connection/ConnectionValidatorRemoteClient.java	2008-04-22 07:14:18 UTC (rev 4036)
@@ -0,0 +1,135 @@
+/*
+* JBoss, Home of Professional Open Source
+* Copyright 2005, JBoss Inc., and individual contributors as indicated
+* by the @authors tag. See the copyright.txt in the distribution for a
+* full listing of individual contributors.
+*
+* This is free software; you can redistribute it and/or modify it
+* under the terms of the GNU Lesser General Public License as
+* published by the Free Software Foundation; either version 2.1 of
+* the License, or (at your option) any later version.
+*
+* This software is distributed in the hope that it will be useful,
+* but WITHOUT ANY WARRANTY; without even the implied warranty of
+* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+* Lesser General Public License for more details.
+*
+* You should have received a copy of the GNU Lesser General Public
+* License along with this software; if not, write to the Free
+* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+*/
+
+package org.jboss.test.remoting.connection;
+
+import java.util.HashMap;
+
+import junit.framework.TestCase;
+
+import org.apache.log4j.ConsoleAppender;
+import org.apache.log4j.Level;
+import org.apache.log4j.Logger;
+import org.apache.log4j.PatternLayout;
+import org.jboss.logging.XLevel;
+import org.jboss.remoting.Client;
+import org.jboss.remoting.ConnectionListener;
+import org.jboss.remoting.ConnectionValidator;
+import org.jboss.remoting.InvokerLocator;
+
+/**
+ * @author <a href="mailto:tom.elrod at jboss.com">Tom Elrod</a>
+ */
+public class ConnectionValidatorRemoteClient extends TestCase implements ConnectionListener
+{
+   private static Logger log = Logger.getLogger(ConnectionValidatorRemoteClient.class);
+   
+   // Default locator values
+   private static String transport = "socket";
+   private static String host = "localhost";
+   private static int port = 5400;
+   String locatorURI = transport + "://" + host + ":" + port;
+   private Throwable validatorResp = null;
+   private int counter = 0;
+
+   private Client remotingClient = null;
+
+   public void testValidator() throws Throwable
+   {
+
+      HashMap config = new HashMap();
+      config.put(ConnectionValidator.VALIDATOR_PING_TIMEOUT, "1000");
+      config.put("timeout", "20000");
+      remotingClient.addConnectionListener(this, config);
+
+      Object response = remotingClient.invoke("Do something");
+
+      log.info("Invocation response: " + response);
+
+      assertNull(validatorResp);
+
+      Thread.currentThread().sleep(30000);
+
+      log.info("validatorResp = " + validatorResp);
+      assertNotNull("Connection listener was not called as expected.", validatorResp);
+      assertEquals(1, counter);
+   }
+
+   public void setUp() throws Exception
+   {
+      Logger.getLogger("org.jboss.remoting").setLevel(XLevel.INFO);
+      Logger.getLogger("org.jboss.test.remoting").setLevel(Level.INFO);
+      String pattern = "[%d{ABSOLUTE}] [%t] %5p (%F:%L) - %m%n";
+      PatternLayout layout = new PatternLayout(pattern);
+      ConsoleAppender consoleAppender = new ConsoleAppender(layout);
+      Logger.getRootLogger().addAppender(consoleAppender);  
+      
+      InvokerLocator locator = new InvokerLocator(locatorURI);
+      log.info("Calling remoting server with locator uri of: " + locatorURI);
+
+      remotingClient = new Client(locator);
+      remotingClient.connect();
+   }
+
+   public void tearDown() throws Exception
+   {
+      if(remotingClient != null)
+      {
+         remotingClient.disconnect();
+      }
+   }
+
+   /**
+    * Can pass transport and port to be used as parameters.
+    * Valid transports are 'rmi' and 'socket'.
+    *
+    * @param args
+    */
+   public static void main(String[] args)
+   {
+      if(args != null && args.length == 3)
+      {
+         transport = args[0];
+         host = args[1];
+         port = Integer.parseInt(args[2]);
+      }
+
+      ConnectionValidatorRemoteClient client = new ConnectionValidatorRemoteClient();
+      try
+      {
+         client.setUp();
+         client.testValidator();
+         client.tearDown();
+      }
+      catch(Throwable e)
+      {
+         e.printStackTrace();
+      }
+   }
+
+   public void handleConnectionException(Throwable throwable, Client client)
+   {
+      log.info("Got connection exception.");
+      validatorResp = throwable;
+      counter++;
+   }
+}
\ No newline at end of file