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

[infinispan-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2009-05-27 06:32:07 -0400 (Wed, 27 May 2009)
New Revision: 349

Modified:
   trunk/core/src/main/java/org/infinispan/remoting/transport/jgroups/JGroupsTransport.java
Log:
Warning message re: FLUSH

Modified: trunk/core/src/main/java/org/infinispan/remoting/transport/jgroups/JGroupsTransport.java
===================================================================
--- trunk/core/src/main/java/org/infinispan/remoting/transport/jgroups/JGroupsTransport.java	2009-05-27 10:25:26 UTC (rev 348)
+++ trunk/core/src/main/java/org/infinispan/remoting/transport/jgroups/JGroupsTransport.java	2009-05-27 10:32:07 UTC (rev 349)
@@ -30,6 +30,7 @@
 import org.jgroups.View;
 import org.jgroups.blocks.GroupRequest;
 import org.jgroups.blocks.RspFilter;
+import org.jgroups.protocols.pbcast.FLUSH;
 import org.jgroups.protocols.pbcast.STREAMING_STATE_TRANSFER;
 import org.jgroups.stack.ProtocolStack;
 import org.jgroups.util.Rsp;
@@ -105,6 +106,12 @@
          throw new CacheException("Unable to start JGroups Channel", e);
       }
       log.info("Cache local address is {0}", getAddress());
+
+      // ensure that the channel has FLUSH enabled.
+      // see ISPN-83 for details.
+      if (channel.getProtocolStack().findProtocol(FLUSH.class) == null) {
+         log.warn("FLUSH is not present in your JGroups stack!  FLUSH is needed to ensure messages are not dropped while new nodes join the cluster.  Will proceed, but inconsistencies may arise!");
+      }
    }
 
    public void stop() {