Uses of Class
org.jgroups.util.MessageBatch

Packages that use MessageBatch

Package	Description
org.jgroups	Provides top-level public JGroups classes such as Channel, Message, etc.
org.jgroups.blocks	Provides building blocks that are layered on top of channels.
org.jgroups.fork
org.jgroups.protocols	Provides implementations of transport protocols which are responsible for sending and receiving messages to/from the network.
org.jgroups.protocols.pbcast
org.jgroups.protocols.relay
org.jgroups.stack	Support for managing protocol stacks.
org.jgroups.tests
org.jgroups.tests.perf
org.jgroups.tests.rt.transports
org.jgroups.util	Provides useful functionality which cannot be assigned to any particular other package.

Uses of MessageBatch in org.jgroups

Methods in org.jgroups with parameters of type MessageBatch

Modifier and Type	Method	Description
default void	Receiver.receive(MessageBatch batch)	Called when a batch of messages is received
JChannel	JChannel.up(MessageBatch batch)	Callback invoked by the protocol stack to deliver a message batch
default void	UpHandler.up(MessageBatch batch)

Uses of MessageBatch in org.jgroups.blocks

Methods in org.jgroups.blocks with parameters of type MessageBatch

Modifier and Type	Method	Description
protected void	RequestCorrelator.iterate(MessageBatch batch, boolean skip_excluded_msgs, boolean process_reqs, boolean process_rsps)
void	RequestCorrelator.receiveMessageBatch(MessageBatch batch)
void	MessageDispatcher.ProtocolAdapter.up(MessageBatch batch)

Uses of MessageBatch in org.jgroups.fork

Methods in org.jgroups.fork with parameters of type MessageBatch

Modifier and Type	Method	Description
void	ForkProtocolStack.up(MessageBatch batch)

Uses of MessageBatch in org.jgroups.protocols

Fields in org.jgroups.protocols with type parameters of type MessageBatch

Modifier and Type	Field	Description
protected static final BiConsumer<MessageBatch,Message>	SEQUENCER2.BATCH_ACCUMULATOR
protected static final BiConsumer<MessageBatch,Message>	UNICAST3.BATCH_ACCUMULATOR

Methods in org.jgroups.protocols with parameters of type MessageBatch

Modifier and Type	Method	Description
protected SHUFFLE	SHUFFLE.add(List<Message> queue, MessageBatch batch, Lock lock, Consumer<Message> send_function)
protected void	SEQUENCER2.deliverBatch(MessageBatch batch)
protected void	UNICAST3.deliverBatch(MessageBatch batch)
protected void	UNICAST3.handleBatchFromSelf(MessageBatch batch, UNICAST3.Entry entry)
protected static int	SIZE.numHeaders(MessageBatch batch)
void	TP.passBatchUp(MessageBatch batch, boolean perform_cluster_name_matching, boolean discard_own_mcast)
protected void	TP.processBatch(MessageBatch batch, boolean oob)
MsgStats	MsgStats.received(MessageBatch batch)
protected void	STATS.received(MessageBatch batch)
protected static void	SHUFFLE.shuffle(MessageBatch batch)
protected long	RATE.size(MessageBatch batch)
void	ASYM_ENCRYPT.up(MessageBatch batch)
void	AUTH.up(MessageBatch batch)
void	BARRIER.up(MessageBatch batch)
void	BATCH.up(MessageBatch batch)
void	BATCH2.up(MessageBatch batch)
void	CLEAR_FLAGS.up(MessageBatch batch)
void	COMPRESS.up(MessageBatch batch)
void	DELAY.up(MessageBatch batch)
void	DH_KEY_EXCHANGE.up(MessageBatch batch)
void	DISCARD.up(MessageBatch batch)
void	Discovery.up(MessageBatch batch)
void	DROP.up(MessageBatch batch)
void	DUPL.up(MessageBatch batch)
void	Encrypt.up(MessageBatch batch)
void	EXAMPLE.up(MessageBatch batch)
void	FailureDetection.up(MessageBatch batch)
void	FD_SOCK2.up(MessageBatch batch)
void	FlowControl.up(MessageBatch batch)
void	FORK.up(MessageBatch batch)
void	FRAG.up(MessageBatch batch)
void	FRAG2.up(MessageBatch batch)
void	FRAG3.up(MessageBatch batch)
void	HDRS.up(MessageBatch batch)
void	MAKE_BATCH.up(MessageBatch batch)
void	MERGE3.up(MessageBatch batch)
void	NON_BLOCKING_SENDS.up(MessageBatch batch)
void	PERF.up(MessageBatch batch)
void	RATE.up(MessageBatch batch)
void	RED.up(MessageBatch batch)
void	REVERSE.up(MessageBatch batch)
void	RSVP.up(MessageBatch batch)
void	SEQUENCER.up(MessageBatch batch)
void	SEQUENCER2.up(MessageBatch batch)
void	SERIALIZE.up(MessageBatch batch)
void	SHUFFLE.up(MessageBatch batch)
void	SIZE.up(MessageBatch batch)
void	SNIFF.up(MessageBatch batch)
void	SOS.up(MessageBatch batch)
void	STATS.up(MessageBatch batch)
void	STOMP.up(MessageBatch batch)
void	THREAD_COUNT.up(MessageBatch batch)
void	TIME.up(MessageBatch batch)	Dividing the delivery time for a batch by the batch size is problematic, e.g.
void	TRACE.up(MessageBatch batch)
void	UNBATCH.up(MessageBatch batch)
void	UNICAST3.up(MessageBatch batch)
void	VERIFY_SUSPECT.up(MessageBatch batch)
void	VERIFY_SUSPECT2.up(MessageBatch batch)

Uses of MessageBatch in org.jgroups.protocols.pbcast

Fields in org.jgroups.protocols.pbcast with type parameters of type MessageBatch

Modifier and Type	Field	Description
protected static final BiConsumer<MessageBatch,Message>	NAKACK2.BATCH_ACCUMULATOR

Methods in org.jgroups.protocols.pbcast with parameters of type MessageBatch

Modifier and Type	Method	Description
protected void	NAKACK2.deliverBatch(MessageBatch batch)
protected void	NAKACK2.handleMessageBatch(MessageBatch mb)
void	FLUSH.up(MessageBatch batch)	Deprecated, for removal: This API element is subject to removal in a future version.
void	GMS.up(MessageBatch batch)
void	NAKACK2.up(MessageBatch mb)
void	STABLE.up(MessageBatch batch)
void	StreamingStateTransfer.up(MessageBatch batch)

Uses of MessageBatch in org.jgroups.protocols.relay

Methods in org.jgroups.protocols.relay with parameters of type MessageBatch

Modifier and Type	Method	Description
void	RELAY2.up(MessageBatch batch)
void	RELAY3.up(MessageBatch batch)

Uses of MessageBatch in org.jgroups.stack

Methods in org.jgroups.stack with parameters of type MessageBatch

Modifier and Type	Method	Description
boolean	MessageProcessingPolicy.process(MessageBatch batch, boolean oob)	Process a batch received from the transport
void	Protocol.up(MessageBatch batch)	Sends up a multiple messages in a MessageBatch.
void	ProtocolStack.up(MessageBatch batch)

Uses of MessageBatch in org.jgroups.tests

Fields in org.jgroups.tests with type parameters of type MessageBatch

Modifier and Type	Field	Description
(package private) final BiConsumer<Short,MessageBatch>	ParseMessages.InnerParseMessages.batch_consumer

Uses of MessageBatch in org.jgroups.tests.perf

Methods in org.jgroups.tests.perf with parameters of type MessageBatch

Modifier and Type	Method	Description
void	MPerf.receive(MessageBatch batch)

Uses of MessageBatch in org.jgroups.tests.rt.transports

Methods in org.jgroups.tests.rt.transports with parameters of type MessageBatch

Modifier and Type	Method	Description
void	JGroupsTransport.receive(MessageBatch batch)

Uses of MessageBatch in org.jgroups.util

Fields in org.jgroups.util declared as MessageBatch

Modifier and Type	Field	Description
protected final MessageBatch	MaxOneThreadPerSender.Entry.batch
protected MessageBatch	SubmitToThreadPool.BatchHandler.batch

Methods in org.jgroups.util that return MessageBatch

Modifier and Type	Method	Description
MessageBatch	MessageBatch.add(Message msg)
MessageBatch	MessageBatch.clear()
MessageBatch	MessageBatch.clusterName(AsciiString name)
MessageBatch	MessageBatch.dest(Address dest)
protected MessageBatch	MessageBatch.determineMode()
MessageBatch	SubmitToThreadPool.BatchHandler.getBatch()
MessageBatch	MessageBatch.mcast(boolean flag)
MessageBatch	MessageBatch.mode(MessageBatch.Mode m)
MessageBatch	MessageBatch.multicast(boolean flag)
static MessageBatch[]	Util.readMessageBatch(DataInput in, boolean multicast, MessageFactory factory)	Reads a list of messages into 2 MessageBatches: regular OOB
MessageBatch	MessageBatch.removeIf(Predicate<Message> filter, boolean match_all)
MessageBatch	MessageBatch.reset()
MessageBatch	MessageBatch.resize(int new_capacity)
MessageBatch	MessageBatch.sender(Address sender)
MessageBatch	MessageBatch.set(Address dest, Address sender, Message[] msgs)
MessageBatch	MessageBatch.setClusterName(AsciiString name)
MessageBatch	MessageBatch.setDest(Address dest)
MessageBatch	MessageBatch.setMode(MessageBatch.Mode m)
MessageBatch	MessageBatch.setSender(Address sender)
MessageBatch	MessageBatch.timestamp(long ts)

Methods in org.jgroups.util with parameters of type MessageBatch

Modifier and Type	Method	Description
int	MessageBatch.add(MessageBatch batch)
int	MessageBatch.add(MessageBatch batch, boolean resize)	Adds another batch to this one
boolean	Table.add(MessageBatch batch, Function<T,Long> seqno_getter)
boolean	Table.add(MessageBatch batch, Function<T,Long> seqno_getter, boolean remove_from_batch, T const_value)	Adds all messages from the given batch to the table
protected boolean	MaxOneThreadPerSender.Entry.allowedToSubmitToThreadPool(MessageBatch msg_batch)
protected static <T> long	Table.findHighestSeqno(MessageBatch batch, Function<T,Long> seqno_getter)
protected boolean	MaxOneThreadPerSender.Entry.process(MessageBatch batch)
protected boolean	MaxOneThreadPerSender.MessageTable.process(MessageBatch batch)
boolean	MaxOneThreadPerSender.process(MessageBatch batch, boolean oob)
boolean	PassRegularMessagesUpDirectly.process(MessageBatch batch, boolean oob)
boolean	SubmitToThreadPool.process(MessageBatch batch, boolean oob)
boolean	UnbatchOOBBatches.process(MessageBatch batch, boolean oob)
protected boolean	SubmitToThreadPool.removeAndDispatchNonBundledMessages(MessageBatch oob_batch)	Removes messages with flags DONT_BUNDLE and OOB set and executes them in the oob or internal thread pool.
protected boolean	MaxOneThreadPerSender.Entry.submit(MessageBatch batch)
int	MessageBatch.transferFrom(MessageBatch other, boolean clear)	Transfers messages from other to this batch.
protected boolean	MaxOneThreadPerSender.Entry.workAvailable(MessageBatch msg_batch)	Called by MaxOneThreadPerSender.BatchHandlerLoop.

Constructors in org.jgroups.util with parameters of type MessageBatch

Modifier	Constructor	Description
	BatchHandler(MessageBatch batch)
	BatchHandlerLoop(MessageBatch batch, MaxOneThreadPerSender.Entry entry, boolean loopback)