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	Supports probabilistic broadcasts.
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 and Description
void	JChannel.up(MessageBatch batch) Callback invoked by the protocol stack to deliver a message batch

Uses of MessageBatch in org.jgroups.blocks

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

Modifier and Type	Method and 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 and Description
void	ForkProtocolStack.up(MessageBatch batch)

Uses of MessageBatch in org.jgroups.protocols

Fields in org.jgroups.protocols declared as MessageBatch

Modifier and Type	Field and Description
protected MessageBatch	TP.BatchHandler.batch

Methods in org.jgroups.protocols that return MessageBatch

Modifier and Type	Method and Description
static MessageBatch[]	TP.readMessageBatch(java.io.DataInput in, boolean multicast) Reads a list of messages into 4 MessageBatches: regular OOB INTERNAL-OOB (INTERNAL and OOB) INTERNAL (INTERNAL)

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

Modifier and Type	Method and Description
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)
protected void	TP.passBatchUp(MessageBatch batch, boolean perform_cluster_name_matching, boolean discard_own_mcast)
protected void	ENCRYPT.Decrypter.queueUpMessage(Message msg, MessageBatch batch)
protected void	TP.removeAndDispatchNonBundledMessages(MessageBatch... oob_batches) Removes messages with flags DONT_BUNDLE and OOB set and executes them in the oob or internal thread pool.
void	RELAY.up(MessageBatch batch)
void	PERF.up(MessageBatch batch)
void	DELIVERY_TIME.up(MessageBatch batch)
void	DUPL.up(MessageBatch batch)
void	FC.up(MessageBatch batch) Deprecated.
void	STATS.up(MessageBatch batch)
void	TRACE.up(MessageBatch batch)
void	DISCARD.up(MessageBatch batch)
void	SASL.up(MessageBatch batch)
void	RSVP.up(MessageBatch batch)
void	UNICAST.up(MessageBatch batch) Deprecated.
void	PRIO.up(MessageBatch batch)
void	SHUFFLE.up(MessageBatch batch)
void	FD.up(MessageBatch batch)
void	FORK.up(MessageBatch batch)
void	ASYM_ENCRYPT.up(MessageBatch batch)
void	MERGE2.up(MessageBatch batch) Deprecated.
void	SIZE.up(MessageBatch batch)
void	SEQUENCER2.up(MessageBatch batch)
void	FRAG.up(MessageBatch batch)
void	STOMP.up(MessageBatch batch)
void	FlowControl.up(MessageBatch batch)
void	HDRS.up(MessageBatch batch)
void	ENCRYPT.up(MessageBatch batch) Deprecated.
void	UNICAST3.up(MessageBatch batch)
void	SEQUENCER.up(MessageBatch batch)
void	EXAMPLE.up(MessageBatch batch)
void	AUTH.up(MessageBatch batch)
void	TP.ProtocolAdapter.up(MessageBatch batch)
void	DELAY.up(MessageBatch batch)
void	BARRIER.up(MessageBatch batch)
void	FD_ALL.up(MessageBatch batch)
void	EncryptBase.up(MessageBatch batch)
void	FD_ALL2.up(MessageBatch batch)
void	FRAG2.up(MessageBatch batch)
void	COMPRESS.up(MessageBatch batch)
void	UNICAST2.up(MessageBatch batch) Deprecated.
void	SCOPE.up(MessageBatch batch) Deprecated.
void	DAISYCHAIN.up(MessageBatch batch)
Message	ENCRYPT.Decrypter.visit(Message msg, MessageBatch batch)
Message	EncryptBase.Decrypter.visit(Message msg, MessageBatch batch)

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

Constructor and Description
BatchHandler(MessageBatch batch)

Uses of MessageBatch in org.jgroups.protocols.pbcast

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

Modifier and Type	Method and Description
protected void	NAKACK2.deliverBatch(MessageBatch batch)
void	STABLE.up(MessageBatch batch)
void	FLUSH.up(MessageBatch batch)
void	NAKACK2.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 and 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 and Description
void	SUPERVISOR.up(MessageBatch batch)

Uses of MessageBatch in org.jgroups.stack

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

Modifier and Type	Method and Description
void	ProtocolStack.up(MessageBatch batch)
void	Protocol.up(MessageBatch batch) Sends up a multiple messages in a MessageBatch.

Uses of MessageBatch in org.jgroups.util

Methods in org.jgroups.util that return MessageBatch

Modifier and Type	Method and Description
MessageBatch	MessageBatch.add(Message msg)
MessageBatch	MessageBatch.clear()
MessageBatch	MessageBatch.clusterName(AsciiString name)
MessageBatch	MessageBatch.dest(Address dest)
MessageBatch	MessageBatch.mode(MessageBatch.Mode mode)
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(Filter<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(Filter<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.sender(Address sender)

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

Modifier and Type	Method and Description
T	MessageBatch.Visitor.visit(Message msg, MessageBatch batch) Called when iterating over the message batch