[infinispan-commits] Infinispan SVN: r1387 - trunk/core/src/main/java/org/infinispan/remoting/transport/jgroups.

[infinispan-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2010-01-18 12:02:29 -0500 (Mon, 18 Jan 2010)
New Revision: 1387

Modified:
   trunk/core/src/main/java/org/infinispan/remoting/transport/jgroups/CommandAwareRpcDispatcher.java
Log:
Ability to force multicasts

Modified: trunk/core/src/main/java/org/infinispan/remoting/transport/jgroups/CommandAwareRpcDispatcher.java
===================================================================
--- trunk/core/src/main/java/org/infinispan/remoting/transport/jgroups/CommandAwareRpcDispatcher.java	2010-01-18 15:45:27 UTC (rev 1386)
+++ trunk/core/src/main/java/org/infinispan/remoting/transport/jgroups/CommandAwareRpcDispatcher.java	2010-01-18 17:02:29 UTC (rev 1387)
@@ -79,6 +79,7 @@
    private Log log = LogFactory.getLog(CommandAwareRpcDispatcher.class);
    AtomicBoolean newCacheStarting = new AtomicBoolean(false);
    AtomicBoolean newCacheStarted = new AtomicBoolean(false);
+   private static final boolean FORCE_MCAST = Boolean.getBoolean("infinispan.unsafe.force_multicast");
 
    public CommandAwareRpcDispatcher() {
    }
@@ -251,7 +252,7 @@
 
          RspList retval = null;
 
-         if (broadcast) {
+         if (broadcast || FORCE_MCAST) {
             RequestOptions opts = new RequestOptions();
             opts.setMode(mode);
             opts.setTimeout(timeout);