[jboss-cvs] JBossRemoting/src/tests/org/jboss/test/remoting/transport/bisocket ...
Ron Sigal
ron_sigal at yahoo.com
Thu Mar 15 18:24:10 EDT 2007
User: rsigal
Date: 07/03/15 18:24:10
Modified: src/tests/org/jboss/test/remoting/transport/bisocket Tag:
remoting_2_x BisocketTestCase.java
Log:
JBREM-727: Fixed reflective access to Client.callbackConnectors.
Revision Changes Path
No revision
No revision
1.1.2.12 +16 -6 JBossRemoting/src/tests/org/jboss/test/remoting/transport/bisocket/BisocketTestCase.java
(In the diff below, changes in quantity of whitespace are not shown.)
Index: BisocketTestCase.java
===================================================================
RCS file: /cvsroot/jboss/JBossRemoting/src/tests/org/jboss/test/remoting/transport/bisocket/BisocketTestCase.java,v
retrieving revision 1.1.2.11
retrieving revision 1.1.2.12
diff -u -b -r1.1.2.11 -r1.1.2.12
--- BisocketTestCase.java 14 Mar 2007 05:10:15 -0000 1.1.2.11
+++ BisocketTestCase.java 15 Mar 2007 22:24:10 -0000 1.1.2.12
@@ -64,7 +64,7 @@
/**
* @author <a href="ron.sigal at jboss.com">Ron Sigal</a>
- * @version $Revision: 1.1.2.11 $
+ * @version $Revision: 1.1.2.12 $
* <p>
* Copyright Nov 25, 2006
* </p>
@@ -1201,7 +1201,9 @@
field.setAccessible(true);
Map callbackConnectors = (Map) field.get(client);
assertEquals(1, callbackConnectors.size());
- Connector callbackConnector = (Connector) callbackConnectors.values().iterator().next();
+ Set callbackConnectorSet = (Set) callbackConnectors.values().iterator().next();
+ assertEquals(1, callbackConnectorSet.size());
+ Connector callbackConnector = (Connector) callbackConnectorSet.iterator().next();
BisocketServerInvoker invoker = (BisocketServerInvoker) callbackConnector.getServerInvoker();
field = BisocketServerInvoker.class.getDeclaredField("controlConnectionThreadMap");
field.setAccessible(true);
@@ -1338,7 +1340,9 @@
field.setAccessible(true);
Map callbackConnectors = (Map) field.get(client);
assertEquals(1, callbackConnectors.size());
- Connector callbackConnector = (Connector) callbackConnectors.values().iterator().next();
+ Set callbackConnectorSet = (Set) callbackConnectors.values().iterator().next();
+ assertEquals(1, callbackConnectorSet.size());
+ Connector callbackConnector = (Connector) callbackConnectorSet.iterator().next();
BisocketServerInvoker invoker = (BisocketServerInvoker) callbackConnector.getServerInvoker();
field = BisocketServerInvoker.class.getDeclaredField("controlConnectionThreadMap");
field.setAccessible(true);
@@ -1423,7 +1427,9 @@
field.setAccessible(true);
Map callbackConnectors = (Map) field.get(client);
assertEquals(1, callbackConnectors.size());
- Connector callbackConnector = (Connector) callbackConnectors.values().iterator().next();
+ Set callbackConnectorSet = (Set) callbackConnectors.values().iterator().next();
+ assertEquals(1, callbackConnectorSet.size());
+ Connector callbackConnector = (Connector) callbackConnectorSet.iterator().next();
ServerInvoker cbsi = callbackConnector.getServerInvoker();
assertTrue(cbsi instanceof BisocketServerInvoker);
field = BisocketServerInvoker.class.getDeclaredField("controlConnectionThreadMap");
@@ -1661,7 +1667,9 @@
Iterator it = callbackConnectors.values().iterator();
while (it.hasNext())
{
- Connector c = (Connector) it.next();
+ Set set = (Set) it.next();
+ assertEquals(1, set.size());
+ Connector c = (Connector) set.iterator().next();
serverInvokers[i] = c.getServerInvoker();
assertTrue(serverInvokers[i] instanceof BisocketServerInvoker);
field = BisocketServerInvoker.class.getDeclaredField("listenerIdToInvokerLocatorMap");
@@ -1786,7 +1794,9 @@
Iterator it = callbackConnectors.values().iterator();
while (it.hasNext())
{
- Connector c = (Connector) it.next();
+ Set set = (Set) it.next();
+ assertEquals(1, set.size());
+ Connector c = (Connector) set.iterator().next();
serverInvokers[i] = c.getServerInvoker();
assertTrue(serverInvokers[i] instanceof BisocketServerInvoker);
field = BisocketServerInvoker.class.getDeclaredField("listenerIdToInvokerLocatorMap");
More information about the jboss-cvs-commits
mailing list