From: Tom E. <tom...@jb...> - 2005-07-07 05:08:18
|
User: telrod Date: 05/07/07 01:07:24 Modified: src/main/org/jboss/remoting InvokerRegistry.java Log: JBREM-153 - fixed bug where local client invoker exists even after server invoker for same locator is removed. Plus added test case. Revision Changes Path 1.11 +6 -2 JBossRemoting/src/main/org/jboss/remoting/InvokerRegistry.java (In the diff below, changes in quantity of whitespace are not shown.) Index: InvokerRegistry.java =================================================================== RCS file: /cvsroot/jboss/JBossRemoting/src/main/org/jboss/remoting/InvokerRegistry.java,v retrieving revision 1.10 retrieving revision 1.11 diff -u -b -r1.10 -r1.11 --- InvokerRegistry.java 5 Jul 2005 15:44:34 -0000 1.10 +++ InvokerRegistry.java 7 Jul 2005 05:07:24 -0000 1.11 @@ -38,7 +38,7 @@ * * @author <a href="mailto:jh...@vo...">Jeff Haynie</a> * @author <a href="mailto:te...@e2...">Tom Elrod</a> - * @version $Revision: 1.10 $ + * @version $Revision: 1.11 $ */ public class InvokerRegistry { @@ -364,7 +364,11 @@ serverLocators.remove(invoker.getLocator()); if(clientLocators.get(locator) instanceof LocalClientInvoker) { - clientLocators.remove(locator); + ClientInvoker clientInvoker = (ClientInvoker)clientLocators.remove(locator); + if(clientInvoker != null) + { + clientInvoker.disconnect(); + } } } } |