Package lumis.portal.cluster.multiserver

Class Sequencer

  • public class Sequencer
extends org.jgroups.protocols.SEQUENCER
    Adapts SEQUENCER to keep the ClusterTransmissionHeader on its generated messages.
    Since:
    4.1.0
    Version:
    $Revision: 23258 $ $Date: 2019-10-09 16:09:02 -0300 (Wed, 09 Oct 2019) $

    • Nested Class Summary

      • Nested classes/interfaces inherited from class org.jgroups.protocols.SEQUENCER

        org.jgroups.protocols.SEQUENCER.Flusher, org.jgroups.protocols.SEQUENCER.SequencerHeader

    • Field Summary

      • Fields inherited from class org.jgroups.protocols.SEQUENCER

        ack_mode, ack_promise, bcast_msgs, coord, delivered_bcasts, delivery_table, delivery_table_max_size, flush_forward_table, flusher, flushing, forward_table, forwarded_msgs, in_flight_sends, is_coord, local_addr, num_acks, received_bcasts, received_forwards, running, send_cond, send_lock, seqno, threshold, view

      • Fields inherited from class org.jgroups.stack.Protocol

        after_creation_hook, down_prot, ergonomics, id, log, stack, stats, up_prot

    • Constructor Summary

      Constructors 
      Constructor Description
      Sequencer()  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected void broadcast​(org.jgroups.Message msg, boolean copy, org.jgroups.Address original_sender, long seqno, boolean resend)  
      protected void forward​(org.jgroups.Message msg, long seqno, boolean flush)  
      protected void unwrapAndDeliver​(org.jgroups.Message msg, boolean flush_ack)  

      • Methods inherited from class org.jgroups.protocols.SEQUENCER

        block, canDeliver, deliver, down, down, flush, flushMessagesInForwardTable, forwardToCoord, getCoordinator, getForwardTableSize, getLocalAddress, handleViewChange, isCoordinator, resetStats, setDeliveryTableMaxSize, setThreshold, start, startFlusher, stop, stopFlusher, unblockAll, up, up, up

      • Methods inherited from class org.jgroups.stack.Protocol

        accept, afterCreationHook, destroy, enableStats, getConfigurableObjects, getDownProtocol, getDownServices, getId, getIdsAbove, getLevel, getLog, getName, getProtocolStack, getSocketFactory, getThreadFactory, getTransport, getUpProtocol, getUpServices, getValue, init, isErgonomics, level, parse, providedDownServices, providedUpServices, requiredDownServices, requiredUpServices, resetStatistics, setDownProtocol, setErgonomics, setId, setLevel, setProtocolStack, setSocketFactory, setUpProtocol, setValue, statsEnabled

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • Sequencer

        public Sequencer()

    • Method Detail

      • forward

        protected void forward​(org.jgroups.Message msg,
                       long seqno,
                       boolean flush)
        Overrides:
        forward in class org.jgroups.protocols.SEQUENCER

      • broadcast

        protected void broadcast​(org.jgroups.Message msg,
                         boolean copy,
                         org.jgroups.Address original_sender,
                         long seqno,
                         boolean resend)
        Overrides:
        broadcast in class org.jgroups.protocols.SEQUENCER

      • unwrapAndDeliver

        protected void unwrapAndDeliver​(org.jgroups.Message msg,
                                boolean flush_ack)
        Overrides:
        unwrapAndDeliver in class org.jgroups.protocols.SEQUENCER