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.protocols.rules
org.jgroups.stack	Support for managing protocol stacks.
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	MessageListener.receive(MessageBatch batch)	Called when a batch of messages is received
void	ReceiverAdapter.receive(MessageBatch batch)
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
void	RequestCorrelator.receiveMessageBatch(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 java.util.function.BiConsumer<MessageBatch,Message>	SEQUENCER2.BATCH_ACCUMULATOR
protected static java.util.function.BiConsumer<MessageBatch,Message>	UNICAST3.BATCH_ACCUMULATOR

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

Modifier and Type	Method	Description
void	Encrypt.Decrypter.accept(Message msg, MessageBatch batch)
protected SHUFFLE	SHUFFLE.add(java.util.List<Message> queue, MessageBatch batch, java.util.concurrent.locks.Lock lock, java.util.function.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, boolean internal)
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	COMPRESS.up(MessageBatch batch)
void	DAISYCHAIN.up(MessageBatch batch)
void	DELAY.up(MessageBatch batch)
void	DELIVERY_TIME.up(MessageBatch batch)
void	DH_KEY_EXCHANGE.up(MessageBatch batch)
void	DISCARD.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.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	NAMING.up(MessageBatch batch)
void	PERF.up(MessageBatch batch)
void	RATE.up(MessageBatch batch)
void	RELAY.up(MessageBatch batch)	Deprecated.
void	REVERSE.up(MessageBatch batch)
void	RSVP.up(MessageBatch batch)
void	SASL.up(MessageBatch batch)	Deprecated.
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	STATS.up(MessageBatch batch)
void	STOMP.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	UNICAST3.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 java.util.function.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)
void	FLUSH.up(MessageBatch batch)
void	NAKACK2.up(MessageBatch batch)
void	STABLE.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)

Uses of MessageBatch in org.jgroups.protocols.rules

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

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

Uses of MessageBatch in org.jgroups.stack

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

Modifier and Type	Method	Description
void	MessageProcessingPolicy.process(MessageBatch batch, boolean oob, boolean internal)	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.util

Fields in org.jgroups.util declared as MessageBatch

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

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

Modifier and Type	Field	Description
protected java.util.function.IntFunction<MessageBatch>	MaxOneThreadPerSender.Entry.batch_creator
protected static java.util.function.ToIntBiFunction<Message,MessageBatch>	MessageBatch.length_visitor
protected static java.util.function.ToLongBiFunction<Message,MessageBatch>	MessageBatch.total_size_visitor

Methods in org.jgroups.util that return MessageBatch

Modifier and Type	Method	Description
MessageBatch	MessageBatch.add(Message msg)
MessageBatch	MessageBatch.add(MessageBatch batch)
MessageBatch	MessageBatch.clear()
MessageBatch	MessageBatch.clusterName(AsciiString name)
MessageBatch	MessageBatch.dest(Address dest)
MessageBatch	MessageBatch.mode(MessageBatch.Mode mode)
MessageBatch	MessageBatch.multicast(boolean flag)
static MessageBatch[]	Util.readMessageBatch(java.io.DataInput in, boolean multicast)	Reads a list of messages into 4 MessageBatches: regular OOB INTERNAL-OOB (INTERNAL and OOB) INTERNAL (INTERNAL)
MessageBatch	MessageBatch.remove(java.util.function.Predicate<Message> filter)	Removes all messages which match filter
MessageBatch	MessageBatch.remove(Message msg)	Removes the current message (found by indentity (==)) by nulling it in the message array
MessageBatch	MessageBatch.replace(java.util.function.Predicate<Message> filter, Message replacement, boolean match_all)	Replaces all messages which match a given filter with a replacement message
MessageBatch	MessageBatch.replace(Message existing_msg, Message new_msg)	Replaces a message in the batch with another one
MessageBatch	MessageBatch.reset()
MessageBatch	MessageBatch.sender(Address sender)
MessageBatch	MessageBatch.setClusterName(AsciiString name)
MessageBatch	MessageBatch.setDest(Address dest)
MessageBatch	MessageBatch.setMode(MessageBatch.Mode mode)
MessageBatch	MessageBatch.setSender(Address sender)

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

Modifier and Type	Method	Description
MessageBatch	MessageBatch.add(MessageBatch batch)
int	MessageBatch.add(MessageBatch batch, boolean resize)	Adds another batch to this one
protected boolean	MaxOneThreadPerSender.Entry.allowedToSubmitToThreadPool(MessageBatch msg_batch)
protected void	MaxOneThreadPerSender.Entry.process(MessageBatch batch)
protected void	MaxOneThreadPerSender.MessageTable.process(MessageBatch batch)
void	MaxOneThreadPerSender.process(MessageBatch batch, boolean oob, boolean internal)
void	SubmitToThreadPool.process(MessageBatch batch, boolean oob, boolean internal)
protected void	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 void	MaxOneThreadPerSender.Entry.submit(MessageBatch mb)
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.

Method parameters in org.jgroups.util with type arguments of type MessageBatch

Modifier and Type	Method	Description
void	MessageBatch.forEach(java.util.function.BiConsumer<Message,MessageBatch> consumer)
<T> java.util.Collection<T>	MessageBatch.map(java.util.function.BiFunction<Message,MessageBatch,T> visitor)	Applies a function to all messages and returns a list of the function results

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

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

Constructor parameters in org.jgroups.util with type arguments of type MessageBatch

Constructor	Description
Entry(java.util.function.IntFunction<MessageBatch> creator)