Class AlternatingBundler

  • All Implemented Interfaces:
    java.lang.Runnable, Bundler

    public class AlternatingBundler
    extends TransferQueueBundler
    Bundler implementation which sends message batches (or single messages) as soon as the target destination changes (or max_bundler_size would be exceeded).
    Messages are removed from the main queue one by one and processed as follows:
    A B B C C A causes the following sends: A -> {CC} -> {BB} -> A
    Note that null is also a valid destination (send-to-all).
    JIRA: https://issues.redhat.com/browse/JGRP-2171
    Since:
    4.0.4
    Author:
    Bela Ban
    • Field Detail

      • target_dest

        protected Address target_dest
      • target_list

        protected final java.util.List<Message> target_list
    • Constructor Detail

      • AlternatingBundler

        public AlternatingBundler()