lumis.portal.cluster.multiserver

Class Sequencer

java.lang.Object

org.jgroups.stack.Protocol

org.jgroups.protocols.SEQUENCER

lumis.portal.cluster.multiserver.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 19:09:02 +0000 (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 and Description
Sequencer()

Method Summary

Modifier and Type	Method and 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