[jboss-cvs] JBossRemoting/src/tests/org/jboss/test/remoting/shutdown/local ...
Ron Sigal
ron_sigal at yahoo.com
Fri Feb 16 00:10:46 EST 2007
User: rsigal
Date: 07/02/16 00:10:46
Modified: src/tests/org/jboss/test/remoting/shutdown/local Tag:
remoting_2_x LocalShutdownTestCase.java
Log:
JBREM-657: Removed substantive test cases since they are no longer applicable.
Revision Changes Path
No revision
No revision
1.1.2.3 +213 -210 JBossRemoting/src/tests/org/jboss/test/remoting/shutdown/local/Attic/LocalShutdownTestCase.java
(In the diff below, changes in quantity of whitespace are not shown.)
Index: LocalShutdownTestCase.java
===================================================================
RCS file: /cvsroot/jboss/JBossRemoting/src/tests/org/jboss/test/remoting/shutdown/local/Attic/LocalShutdownTestCase.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
--- LocalShutdownTestCase.java 7 Feb 2007 07:02:16 -0000 1.1.2.2
+++ LocalShutdownTestCase.java 16 Feb 2007 05:10:46 -0000 1.1.2.3
@@ -52,7 +52,7 @@
* Client.removeListenerLocal() do not attempt to contact the server.
*
* @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 Jan 18, 2007
* </p>
@@ -77,221 +77,224 @@
}
}
-
- public void testDisconnectLocal() throws Throwable
- {
- log.info("entering " + getName());
-
- // Start server.
- String host = InetAddress.getLocalHost().getHostAddress();
- int port = PortUtil.findFreePort(host);
- String locatorURI = "socket://" + host + ":" + port;
- InvokerLocator locator = new InvokerLocator(locatorURI);
- HashMap serverConfig = new HashMap();
- Connector connector = new Connector(locator, serverConfig);
- connector.create();
- connector.addInvocationHandler("test", new TestHandler());
- connector.addConnectionListener(new TestListener());
- connector.start();
-
- // Connect client, verify that a lease exists, then disconnect client
- // and verify that lease has been removed on server.
- HashMap clientConfig = new HashMap();
- clientConfig.put(InvokerLocator.FORCE_REMOTE, "true");
- clientConfig.put(Client.ENABLE_LEASE, "true");
- clientConfig.put(InvokerLocator.CLIENT_LEASE_PERIOD, "1000");
- Client client = new Client(locator, clientConfig);
- client.connect();
- Integer i = (Integer) client.invoke(new Integer(7));
- assertEquals(8, i.intValue());
- Thread.sleep(1000);
- ServerInvoker serverInvoker = connector.getServerInvoker();
- Field field = ServerInvoker.class.getDeclaredField("clientLeases");
- field.setAccessible(true);
- Map clientLeases = (Map) field.get(serverInvoker);
- assertEquals(1, clientLeases.size());
- field = MicroRemoteClientInvoker.class.getDeclaredField("invokerSessionID");
- field.setAccessible(true);
- String invokerSessionId = (String) field.get(client.getInvoker());
- assertTrue(clientLeases.containsKey(invokerSessionId));
- client.disconnect();
- assertEquals(0, clientLeases.size());
-
- // Connect new client, verify that a lease exists, then locally disconnect
- // client and verify that lease still exists on server.
- client = new Client(locator, clientConfig);
- client.connect();
- i = (Integer) client.invoke(new Integer(11));
- assertEquals(12, i.intValue());
- Thread.sleep(1000);
- assertEquals(1, clientLeases.size());
- invokerSessionId = (String) field.get(client.getInvoker());
- assertTrue(clientLeases.containsKey(invokerSessionId));
- client.disconnectLocal();
- assertEquals(1, clientLeases.size());
- assertTrue(clientLeases.containsKey(invokerSessionId));
-
- connector.stop();
- log.info(getName() + " PASSES");
- }
-
-
- public void testRemoveListenerLocalPushCallbacks() throws Throwable
+ public void testDummy()
{
- log.info("entering " + getName());
-
- // Start server.
- String host = InetAddress.getLocalHost().getHostAddress();
- int port = PortUtil.findFreePort(host);
- String locatorURI = "socket://" + host + ":" + port;
- InvokerLocator locator = new InvokerLocator(locatorURI);
- HashMap serverConfig = new HashMap();
- serverConfig.put(InvokerLocator.FORCE_REMOTE, "true");
- Connector connector = new Connector(locator, serverConfig);
- connector.create();
- connector.addInvocationHandler("test", new TestHandler());
- connector.start();
-
- // Connect client, add a callback handler, then call Client.removeListener()
- // and verify that callback handler has been removed on server.
- HashMap clientConfig = new HashMap();
- clientConfig.put(InvokerLocator.FORCE_REMOTE, "true");
- Client client = new Client(locator, clientConfig);
- client.connect();
- Integer i = (Integer) client.invoke(new Integer(7));
- assertEquals(8, i.intValue());
- TestCallbackHandler callbackHandler = new TestCallbackHandler();
- client.addListener(callbackHandler, null, null, true);
- ServerInvoker serverInvoker = connector.getServerInvoker();
- Field field = ServerInvoker.class.getDeclaredField("callbackHandlers");
- field.setAccessible(true);
- Map callbackHandlers = (Map) field.get(serverInvoker);
- assertEquals(1, callbackHandlers.size());
- client.removeListener(callbackHandler);
- assertEquals(0, callbackHandlers.size());
- client.disconnect();
-
- // Connect client, add a callback handler, then call Client.removeListenerLocal()
- // and verify that callback handler still exists on server.
- client = new Client(locator, clientConfig);
- client.connect();
- i = (Integer) client.invoke(new Integer(11));
- assertEquals(12, i.intValue());
- callbackHandler = new TestCallbackHandler();
- client.addListener(callbackHandler, null, null, true);
- assertEquals(1, callbackHandlers.size());
- client.removeListenerLocal(callbackHandler);
- assertEquals(1, callbackHandlers.size());
- client.disconnect();
- connector.stop();
- log.info(getName() + " PASSES");
}
-
-
- public void testRemoveListenerLocalPolledCallbacks() throws Throwable
- {
- log.info("entering " + getName());
-
- // Start server.
- String host = InetAddress.getLocalHost().getHostAddress();
- int port = PortUtil.findFreePort(host);
- String locatorURI = "socket://" + host + ":" + port;
- InvokerLocator locator = new InvokerLocator(locatorURI);
- HashMap serverConfig = new HashMap();
- serverConfig.put(InvokerLocator.FORCE_REMOTE, "true");
- Connector connector = new Connector(locator, serverConfig);
- connector.create();
- connector.addInvocationHandler("test", new TestHandler());
- connector.start();
-
- // Connect client, add a callback handler, then call Client.removeListener()
- // and verify that callback handler has been removed on server.
- HashMap clientConfig = new HashMap();
- clientConfig.put(InvokerLocator.FORCE_REMOTE, "true");
- Client client = new Client(locator, clientConfig);
- client.connect();
- Integer i = (Integer) client.invoke(new Integer(7));
- assertEquals(8, i.intValue());
- TestCallbackHandler callbackHandler = new TestCallbackHandler();
- client.addListener(callbackHandler, null, null, false);
- ServerInvoker serverInvoker = connector.getServerInvoker();
- Field field = ServerInvoker.class.getDeclaredField("callbackHandlers");
- field.setAccessible(true);
- Map callbackHandlers = (Map) field.get(serverInvoker);
- assertEquals(1, callbackHandlers.size());
- client.removeListener(callbackHandler);
- assertEquals(0, callbackHandlers.size());
- client.disconnect();
-
- // Connect client, add a callback handler, then call Client.removeListenerLocal()
- // and verify that callback handler still exists on server.
- client = new Client(locator, clientConfig);
- client.connect();
- i = (Integer) client.invoke(new Integer(11));
- assertEquals(12, i.intValue());
- callbackHandler = new TestCallbackHandler();
- client.addListener(callbackHandler, null, null, false);
- assertEquals(1, callbackHandlers.size());
- client.removeListenerLocal(callbackHandler);
- assertEquals(1, callbackHandlers.size());
- client.disconnect();
-
- connector.stop();
- log.info(getName() + " PASSES");
- }
-
-
- public void testRemoveListenerLocalPullCallbacks() throws Throwable
- {
- log.info("entering " + getName());
-
- // Start server.
- String host = InetAddress.getLocalHost().getHostAddress();
- int port = PortUtil.findFreePort(host);
- String locatorURI = "socket://" + host + ":" + port;
- InvokerLocator locator = new InvokerLocator(locatorURI);
- HashMap serverConfig = new HashMap();
- serverConfig.put(InvokerLocator.FORCE_REMOTE, "true");
- Connector connector = new Connector(locator, serverConfig);
- connector.create();
- connector.addInvocationHandler("test", new TestHandler());
- connector.start();
-
- // Connect client, add a callback handler, then call Client.removeListener()
- // and verify that callback handler has been removed on server.
- HashMap clientConfig = new HashMap();
- clientConfig.put(InvokerLocator.FORCE_REMOTE, "true");
- Client client = new Client(locator, clientConfig);
- client.connect();
- Integer i = (Integer) client.invoke(new Integer(7));
- assertEquals(8, i.intValue());
- TestCallbackHandler callbackHandler = new TestCallbackHandler();
- client.addListener(callbackHandler);
- ServerInvoker serverInvoker = connector.getServerInvoker();
- Field field = ServerInvoker.class.getDeclaredField("callbackHandlers");
- field.setAccessible(true);
- Map callbackHandlers = (Map) field.get(serverInvoker);
- assertEquals(1, callbackHandlers.size());
- client.removeListener(callbackHandler);
- assertEquals(0, callbackHandlers.size());
- client.disconnect();
-
- // Connect client, add a callback handler, then call Client.removeListenerLocal()
- // and verify that callback handler still exists on server.
- client = new Client(locator, clientConfig);
- client.connect();
- i = (Integer) client.invoke(new Integer(11));
- assertEquals(12, i.intValue());
- callbackHandler = new TestCallbackHandler();
- client.addListener(callbackHandler);
- assertEquals(1, callbackHandlers.size());
- client.removeListenerLocal(callbackHandler);
- assertEquals(1, callbackHandlers.size());
- client.disconnect();
-
- connector.stop();
- log.info(getName() + " PASSES");
+// public void testDisconnectLocal() throws Throwable
+// {
+// log.info("entering " + getName());
+//
+// // Start server.
+// String host = InetAddress.getLocalHost().getHostAddress();
+// int port = PortUtil.findFreePort(host);
+// String locatorURI = "socket://" + host + ":" + port;
+// InvokerLocator locator = new InvokerLocator(locatorURI);
+// HashMap serverConfig = new HashMap();
+// Connector connector = new Connector(locator, serverConfig);
+// connector.create();
+// connector.addInvocationHandler("test", new TestHandler());
+// connector.addConnectionListener(new TestListener());
+// connector.start();
+//
+// // Connect client, verify that a lease exists, then disconnect client
+// // and verify that lease has been removed on server.
+// HashMap clientConfig = new HashMap();
+// clientConfig.put(InvokerLocator.FORCE_REMOTE, "true");
+// clientConfig.put(Client.ENABLE_LEASE, "true");
+// clientConfig.put(InvokerLocator.CLIENT_LEASE_PERIOD, "1000");
+// Client client = new Client(locator, clientConfig);
+// client.connect();
+// Integer i = (Integer) client.invoke(new Integer(7));
+// assertEquals(8, i.intValue());
+// Thread.sleep(1000);
+// ServerInvoker serverInvoker = connector.getServerInvoker();
+// Field field = ServerInvoker.class.getDeclaredField("clientLeases");
+// field.setAccessible(true);
+// Map clientLeases = (Map) field.get(serverInvoker);
+// assertEquals(1, clientLeases.size());
+// field = MicroRemoteClientInvoker.class.getDeclaredField("invokerSessionId");
+// field.setAccessible(true);
+// String invokerSessionId = (String) field.get(client.getInvoker());
+// assertTrue(clientLeases.containsKey(invokerSessionId));
+// client.disconnect();
+// assertEquals(0, clientLeases.size());
+//
+// // Connect new client, verify that a lease exists, then locally disconnect
+// // client and verify that lease still exists on server.
+// client = new Client(locator, clientConfig);
+// client.connect();
+// i = (Integer) client.invoke(new Integer(11));
+// assertEquals(12, i.intValue());
+// Thread.sleep(1000);
+// assertEquals(1, clientLeases.size());
+// invokerSessionId = (String) field.get(client.getInvoker());
+// assertTrue(clientLeases.containsKey(invokerSessionId));
+// client.disconnectLocal();
+// assertEquals(1, clientLeases.size());
+// assertTrue(clientLeases.containsKey(invokerSessionId));
+//
+// connector.stop();
+// log.info(getName() + " PASSES");
+// }
+
+
+// public void testRemoveListenerLocalPushCallbacks() throws Throwable
+ {
+// log.info("entering " + getName());
+//
+// // Start server.
+// String host = InetAddress.getLocalHost().getHostAddress();
+// int port = PortUtil.findFreePort(host);
+// String locatorURI = "socket://" + host + ":" + port;
+// InvokerLocator locator = new InvokerLocator(locatorURI);
+// HashMap serverConfig = new HashMap();
+// serverConfig.put(InvokerLocator.FORCE_REMOTE, "true");
+// Connector connector = new Connector(locator, serverConfig);
+// connector.create();
+// connector.addInvocationHandler("test", new TestHandler());
+// connector.start();
+//
+// // Connect client, add a callback handler, then call Client.removeListener()
+// // and verify that callback handler has been removed on server.
+// HashMap clientConfig = new HashMap();
+// clientConfig.put(InvokerLocator.FORCE_REMOTE, "true");
+// Client client = new Client(locator, clientConfig);
+// client.connect();
+// Integer i = (Integer) client.invoke(new Integer(7));
+// assertEquals(8, i.intValue());
+// TestCallbackHandler callbackHandler = new TestCallbackHandler();
+// client.addListener(callbackHandler, null, null, true);
+// ServerInvoker serverInvoker = connector.getServerInvoker();
+// Field field = ServerInvoker.class.getDeclaredField("callbackHandlers");
+// field.setAccessible(true);
+// Map callbackHandlers = (Map) field.get(serverInvoker);
+// assertEquals(1, callbackHandlers.size());
+// client.removeListener(callbackHandler);
+// assertEquals(0, callbackHandlers.size());
+// client.disconnect();
+//
+// // Connect client, add a callback handler, then call Client.removeListenerLocal()
+// // and verify that callback handler still exists on server.
+// client = new Client(locator, clientConfig);
+// client.connect();
+// i = (Integer) client.invoke(new Integer(11));
+// assertEquals(12, i.intValue());
+// callbackHandler = new TestCallbackHandler();
+// client.addListener(callbackHandler, null, null, true);
+// assertEquals(1, callbackHandlers.size());
+// client.removeListenerLocal(callbackHandler);
+// assertEquals(1, callbackHandlers.size());
+// client.disconnect();
+//
+// connector.stop();
+// log.info(getName() + " PASSES");
+// }
+//
+//
+// public void testRemoveListenerLocalPolledCallbacks() throws Throwable
+// {
+// log.info("entering " + getName());
+//
+// // Start server.
+// String host = InetAddress.getLocalHost().getHostAddress();
+// int port = PortUtil.findFreePort(host);
+// String locatorURI = "socket://" + host + ":" + port;
+// InvokerLocator locator = new InvokerLocator(locatorURI);
+// HashMap serverConfig = new HashMap();
+// serverConfig.put(InvokerLocator.FORCE_REMOTE, "true");
+// Connector connector = new Connector(locator, serverConfig);
+// connector.create();
+// connector.addInvocationHandler("test", new TestHandler());
+// connector.start();
+//
+// // Connect client, add a callback handler, then call Client.removeListener()
+// // and verify that callback handler has been removed on server.
+// HashMap clientConfig = new HashMap();
+// clientConfig.put(InvokerLocator.FORCE_REMOTE, "true");
+// Client client = new Client(locator, clientConfig);
+// client.connect();
+// Integer i = (Integer) client.invoke(new Integer(7));
+// assertEquals(8, i.intValue());
+// TestCallbackHandler callbackHandler = new TestCallbackHandler();
+// client.addListener(callbackHandler, null, null, false);
+// ServerInvoker serverInvoker = connector.getServerInvoker();
+// Field field = ServerInvoker.class.getDeclaredField("callbackHandlers");
+// field.setAccessible(true);
+// Map callbackHandlers = (Map) field.get(serverInvoker);
+// assertEquals(1, callbackHandlers.size());
+// client.removeListener(callbackHandler);
+// assertEquals(0, callbackHandlers.size());
+// client.disconnect();
+//
+// // Connect client, add a callback handler, then call Client.removeListenerLocal()
+// // and verify that callback handler still exists on server.
+// client = new Client(locator, clientConfig);
+// client.connect();
+// i = (Integer) client.invoke(new Integer(11));
+// assertEquals(12, i.intValue());
+// callbackHandler = new TestCallbackHandler();
+// client.addListener(callbackHandler, null, null, false);
+// assertEquals(1, callbackHandlers.size());
+// client.removeListenerLocal(callbackHandler);
+// assertEquals(1, callbackHandlers.size());
+// client.disconnect();
+//
+// connector.stop();
+// log.info(getName() + " PASSES");
+// }
+//
+//
+// public void testRemoveListenerLocalPullCallbacks() throws Throwable
+// {
+// log.info("entering " + getName());
+//
+// // Start server.
+// String host = InetAddress.getLocalHost().getHostAddress();
+// int port = PortUtil.findFreePort(host);
+// String locatorURI = "socket://" + host + ":" + port;
+// InvokerLocator locator = new InvokerLocator(locatorURI);
+// HashMap serverConfig = new HashMap();
+// serverConfig.put(InvokerLocator.FORCE_REMOTE, "true");
+// Connector connector = new Connector(locator, serverConfig);
+// connector.create();
+// connector.addInvocationHandler("test", new TestHandler());
+// connector.start();
+//
+// // Connect client, add a callback handler, then call Client.removeListener()
+// // and verify that callback handler has been removed on server.
+// HashMap clientConfig = new HashMap();
+// clientConfig.put(InvokerLocator.FORCE_REMOTE, "true");
+// Client client = new Client(locator, clientConfig);
+// client.connect();
+// Integer i = (Integer) client.invoke(new Integer(7));
+// assertEquals(8, i.intValue());
+// TestCallbackHandler callbackHandler = new TestCallbackHandler();
+// client.addListener(callbackHandler);
+// ServerInvoker serverInvoker = connector.getServerInvoker();
+// Field field = ServerInvoker.class.getDeclaredField("callbackHandlers");
+// field.setAccessible(true);
+// Map callbackHandlers = (Map) field.get(serverInvoker);
+// assertEquals(1, callbackHandlers.size());
+// client.removeListener(callbackHandler);
+// assertEquals(0, callbackHandlers.size());
+// client.disconnect();
+//
+// // Connect client, add a callback handler, then call Client.removeListenerLocal()
+// // and verify that callback handler still exists on server.
+// client = new Client(locator, clientConfig);
+// client.connect();
+// i = (Integer) client.invoke(new Integer(11));
+// assertEquals(12, i.intValue());
+// callbackHandler = new TestCallbackHandler();
+// client.addListener(callbackHandler);
+// assertEquals(1, callbackHandlers.size());
+// client.removeListenerLocal(callbackHandler);
+// assertEquals(1, callbackHandlers.size());
+// client.disconnect();
+//
+// connector.stop();
+// log.info(getName() + " PASSES");
}
More information about the jboss-cvs-commits
mailing list