[infinispan-commits] Infinispan SVN: r1981 - in trunk/core/src: test/java/org/infinispan/jmx and 1 other directory.

[infinispan-commits at lists.jboss.org]

Author: galder.zamarreno at jboss.com
Date: 2010-07-06 04:50:57 -0400 (Tue, 06 Jul 2010)
New Revision: 1981

Modified:
   trunk/core/src/main/java/org/infinispan/remoting/rpc/RpcManagerImpl.java
   trunk/core/src/test/java/org/infinispan/jmx/RpcManagerMBeanTest.java
Log:
Fix retry logic implementation regression where RpcManager implementation managed attribute name changed.

Modified: trunk/core/src/main/java/org/infinispan/remoting/rpc/RpcManagerImpl.java
===================================================================
--- trunk/core/src/main/java/org/infinispan/remoting/rpc/RpcManagerImpl.java	2010-07-06 08:45:13 UTC (rev 1980)
+++ trunk/core/src/main/java/org/infinispan/remoting/rpc/RpcManagerImpl.java	2010-07-06 08:50:57 UTC (rev 1981)
@@ -383,8 +383,9 @@
    // mainly for unit testing
    public void setTransport(Transport t) {
       this.t = t;
-   }@Override
+   }
 
+   @Override
    public Address getAddress() {
       return t != null ? t.getAddress() : null;
    }

Modified: trunk/core/src/test/java/org/infinispan/jmx/RpcManagerMBeanTest.java
===================================================================
--- trunk/core/src/test/java/org/infinispan/jmx/RpcManagerMBeanTest.java	2010-07-06 08:45:13 UTC (rev 1980)
+++ trunk/core/src/test/java/org/infinispan/jmx/RpcManagerMBeanTest.java	2010-07-06 08:50:57 UTC (rev 1981)
@@ -210,8 +210,8 @@
       ObjectName rpcManager2 = new ObjectName("RpcManagerMBeanTest2:cache-name=" + cachename + "(repl_sync),jmx-resource=RpcManager");
       String cm1Address = manager(0).getAddress().toString();
       String cm2Address = manager(1).getAddress().toString();
-      assert mBeanServer.getAttribute(rpcManager1, "Address").equals(cm1Address);
-      assert mBeanServer.getAttribute(rpcManager2, "Address").equals(cm2Address);
+      assert mBeanServer.getAttribute(rpcManager1, "NodeAddress").equals(cm1Address);
+      assert mBeanServer.getAttribute(rpcManager2, "NodeAddress").equals(cm2Address);
 
       String cm1Members = mBeanServer.getAttribute(rpcManager1, "Members").toString();
       assert cm1Members.contains(cm1Address);