[infinispan-commits] Infinispan SVN: r1734 - in trunk/core/src/main/java/org/infinispan: remoting/rpc and 1 other directory.

[infinispan-commits at lists.jboss.org]

Author: galder.zamarreno at jboss.com
Date: 2010-05-03 05:22:06 -0400 (Mon, 03 May 2010)
New Revision: 1734

Modified:
   trunk/core/src/main/java/org/infinispan/config/GlobalConfiguration.java
   trunk/core/src/main/java/org/infinispan/remoting/rpc/RpcManagerImpl.java
Log:
Added log message for invoke future calls and clarified comment on default for transport class when transport element is defined.

Modified: trunk/core/src/main/java/org/infinispan/config/GlobalConfiguration.java
===================================================================
--- trunk/core/src/main/java/org/infinispan/config/GlobalConfiguration.java	2010-05-03 09:20:23 UTC (rev 1733)
+++ trunk/core/src/main/java/org/infinispan/config/GlobalConfiguration.java	2010-05-03 09:22:06 UTC (rev 1734)
@@ -593,7 +593,7 @@
        * @configRef desc="Fully qualified name of a class that represents a network transport.  Must implement
        * org.infinispan.remoting.transport.Transport"
        */
-      protected String transportClass = null; // this defaults to a non-clustered cache.
+      protected String transportClass = null; // The default constructor sets default to JGroupsTransport
 
       /**
        * @configRef desc="Name of the current node.  This is a friendly name to make logs, etc. make more sense.

Modified: trunk/core/src/main/java/org/infinispan/remoting/rpc/RpcManagerImpl.java
===================================================================
--- trunk/core/src/main/java/org/infinispan/remoting/rpc/RpcManagerImpl.java	2010-05-03 09:20:23 UTC (rev 1733)
+++ trunk/core/src/main/java/org/infinispan/remoting/rpc/RpcManagerImpl.java	2010-05-03 09:22:06 UTC (rev 1734)
@@ -241,6 +241,7 @@
    }
 
    public final void invokeRemotelyInFuture(final Collection<Address> recipients, final ReplicableCommand rpc, final boolean usePriorityQueue, final NotifyingNotifiableFuture<Object> l, final long timeout) {
+      if (trace) log.trace("{0} invoking in future call {1} to recipient list {2}", t.getAddress(), rpc, recipients); 
       Callable<Object> c = new Callable<Object>() {
          public Object call() {
             invokeRemotely(recipients, rpc, true, usePriorityQueue, timeout);