Try DONT_BUNDLE instead of no-bundler

infinispan · Jan 16, 2017 · 3414b80 · 3414b80
1 parent 9877512
commit 3414b80
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/core/src/main/java/org/infinispan/remoting/transport/jgroups/CommandAwareRpcDispatcher.java b/core/src/main/java/org/infinispan/remoting/transport/jgroups/CommandAwareRpcDispatcher.java
@@ -54,7 +54,7 @@ public class CommandAwareRpcDispatcher extends MessageDispatcher {
          SecurityActions.getIntProperty("infinispan.stagger.delay", 5));
    public static final short REPLY_FLAGS_TO_CLEAR = (short) (Message.Flag.RSVP.value() | Message.Flag.INTERNAL.value());
    public static final short REPLY_FLAGS_TO_SET =
-         (short) (Message.Flag.NO_FC.value() | Message.Flag.OOB.value() | Message.Flag.NO_TOTAL_ORDER.value());
+         (short) (Message.Flag.NO_FC.value() | Message.Flag.OOB.value() | Message.Flag.NO_TOTAL_ORDER.value() | Message.Flag.DONT_BUNDLE.value());
 
    private final InboundInvocationHandler handler;
    private final ScheduledExecutorService timeoutExecutor;
@@ -253,7 +253,7 @@ static RequestOptions constructRequestOptions(ResponseMode mode, boolean rsvp, D
          options.setTransientFlags(Message.TransientFlag.DONT_LOOPBACK.value());
       }
       if (rsvp) {
-         options.setFlags(Message.Flag.RSVP.value());
+         options.setFlags((short) (Message.Flag.RSVP.value() | Message.Flag.DONT_BUNDLE.value()));
       }
       return options;
    }

diff --git a/core/src/main/resources/default-configs/default-jgroups-udp.xml b/core/src/main/resources/default-configs/default-jgroups-udp.xml
@@ -10,7 +10,7 @@
         ip_ttl="${jgroups.ip_ttl:2}"
         thread_naming_pattern="pl"
         enable_diagnostics="false"
-        bundler_type="no-bundler"
+        bundler_type="ring-buffer-lockless2"
 
         thread_pool.min_threads="${jgroups.thread_pool.min_threads:0}"
         thread_pool.max_threads="${jgroups.thread_pool.max_threads:200}"