java.lang.Object
- org.jgroups.util.MessageBatch

All Implemented Interfaces:

java.lang.Iterable<Message>
```
public class MessageBatch
extends java.lang.Object
implements java.lang.Iterable<Message>
```
Represents a message batch; multiple messages from the same sender to the same receiver(s). This class is unsynchronized.

Since:

3.3

Author:

Bela Ban

Nested Class Summary

Nested Classes
Modifier and Type Class Description

static class MessageBatch.Mode

Field Summary

Fields
Modifier and Type	Field	Description
`protected AsciiString`	`cluster_name`	The name of the cluster in which the message batch is sent, this is equivalent to TpHeader.cluster_name
`protected Address`	`dest`	The destination address.
`protected FastArray<Message>`	`messages`	The storage of the messages; removed messages have a null element
`protected MessageBatch.Mode`	`mode`	Whether this message batch contains only OOB messages, or only regular messages
`protected boolean`	`multicast`	Whether all messages have dest == null (multicast) or not
`protected Address`	`sender`	The sender of the message batch
`protected long`	`timestamp`	For benchmarking; may get removed without notice

Constructor Summary

Constructors
Constructor	Description
`MessageBatch()`
`MessageBatch(int capacity)`
`MessageBatch(java.util.Collection<Message> msgs)`
`MessageBatch(Address dest, Address sender, AsciiString cluster_name, boolean multicast, java.util.Collection<Message> msgs)`
`MessageBatch(Address dest, Address sender, AsciiString cluster_name, boolean multicast, MessageBatch.Mode mode, int capacity)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`MessageBatch`	`add(java.util.Collection<Message> msgs)`
`MessageBatch`	`add(Message msg)`
`MessageBatch`	`add(Message[] msgs, int num_msgs)`	Adds message to this batch from a message array
`MessageBatch`	`add(Message msg, boolean resize)`	Adds a message to the table
`MessageBatch`	`add(Message msg, boolean resize, boolean determine_mode)`	Adds a message to the table
`MessageBatch`	`add(MessageBatch batch)`
`MessageBatch`	`add(MessageBatch batch, boolean resize)`	Adds another batch to this one
`boolean`	`anyMatch(java.util.function.Predicate<Message> pred)`
`FastArray<Message>`	`array()`	Returns the underlying message array.
`int`	`capacity()`
`MessageBatch`	`clear()`
`MessageBatch`	`cluster(AsciiString name)`
`AsciiString`	`clusterName()`
`MessageBatch`	`clusterName(AsciiString name)`
`Address`	`dest()`
`MessageBatch`	`dest(Address dest)`
`MessageBatch`	`determineMode()`
`<T extends Message> T`	`first()`
`AsciiString`	`getClusterName()`
`Address`	`getDest()`
`MessageBatch.Mode`	`getMode()`
`Address`	`getSender()`
`MessageBatch`	`increment(int i)`
`boolean`	`isEmpty()`
`boolean`	`isMulticast()`
`java.util.Iterator<Message>`	`iterator()`	Iterator which iterates only over non-null messages, skipping null messages
`java.util.Iterator<Message>`	`iterator(java.util.function.Predicate<Message> filter)`	Iterates over all non-null message which match filter
`<T extends Message> T`	`last()`
`int`	`length()`	Returns the total number of bytes of the message batch (by calling `Message.getLength()` on all messages)
`MessageBatch`	`mcast(boolean flag)`
`MessageBatch.Mode`	`mode()`
`MessageBatch`	`mode(MessageBatch.Mode m)`
`boolean`	`multicast()`
`MessageBatch`	`multicast(boolean flag)`
`java.lang.String`	`printHeaders()`
`MessageBatch`	`removeIf(java.util.function.Predicate<Message> filter, boolean match_all)`
`MessageBatch`	`reset()`
`MessageBatch`	`resize(int new_capacity)`
`Address`	`sender()`
`MessageBatch`	`sender(Address sender)`
`MessageBatch`	`set(Address dest, Address sender, Message[] msgs)`
`MessageBatch`	`setClusterName(AsciiString name)`
`MessageBatch`	`setDest(Address dest)`
`MessageBatch`	`setMode(MessageBatch.Mode m)`
`MessageBatch`	`setSender(Address sender)`
`int`	`size()`	Returns the number of non-null messages
`java.util.stream.Stream<Message>`	`stream()`
`java.util.stream.Stream<Message>`	`stream(java.util.function.Predicate<Message> p)`
`java.util.stream.Stream<Message>`	`stream(java.util.function.Predicate<Message> p, boolean parallel)`
`long`	`timestamp()`
`MessageBatch`	`timestamp(long ts)`
`java.lang.String`	`toString()`
`long`	`totalSize()`	Returns the size of the message batch (by calling `Message.size()` on all messages)
`int`	`transferFrom(MessageBatch other, boolean clear)`	Transfers messages from other to this batch.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.lang.Iterable
forEach, spliterator

Field Detail
- dest
```
protected Address dest
```
  The destination address. Null if this is a multicast message batch, non-null if the batch is sent to a specific member
- sender
```
protected Address sender
```
  The sender of the message batch
- cluster_name
```
protected AsciiString cluster_name
```
  The name of the cluster in which the message batch is sent, this is equivalent to TpHeader.cluster_name
- messages
```
protected FastArray<Message> messages
```
  The storage of the messages; removed messages have a null element
- multicast
```
protected boolean multicast
```
  Whether all messages have dest == null (multicast) or not
- mode
```
protected MessageBatch.Mode mode
```
  Whether this message batch contains only OOB messages, or only regular messages
- timestamp
```
protected long timestamp
```
  For benchmarking; may get removed without notice

Constructor Detail

MessageBatch
```
public MessageBatch()
```

MessageBatch
```
public MessageBatch(int capacity)
```

MessageBatch

public MessageBatch(java.util.Collection<Message> msgs)

MessageBatch

public MessageBatch(Address dest,
                    Address sender,
                    AsciiString cluster_name,
                    boolean multicast,
                    java.util.Collection<Message> msgs)

MessageBatch

public MessageBatch(Address dest,
                    Address sender,
                    AsciiString cluster_name,
                    boolean multicast,
                    MessageBatch.Mode mode,
                    int capacity)

Method Detail

getDest
```
public Address getDest()
```

dest
```
public Address dest()
```

setDest

public MessageBatch setDest(Address dest)

dest

public MessageBatch dest(Address dest)

getSender
```
public Address getSender()
```

sender
```
public Address sender()
```

setSender

public MessageBatch setSender(Address sender)

sender

public MessageBatch sender(Address sender)

getClusterName
```
public AsciiString getClusterName()
```

clusterName
```
public AsciiString clusterName()
```

setClusterName

public MessageBatch setClusterName(AsciiString name)

clusterName

public MessageBatch clusterName(AsciiString name)

cluster

public MessageBatch cluster(AsciiString name)

isMulticast
```
public boolean isMulticast()
```

multicast
```
public boolean multicast()
```

multicast

public MessageBatch multicast(boolean flag)

mcast

public MessageBatch mcast(boolean flag)

getMode
```
public MessageBatch.Mode getMode()
```

mode
```
public MessageBatch.Mode mode()
```

setMode

public MessageBatch setMode(MessageBatch.Mode m)

mode

public MessageBatch mode(MessageBatch.Mode m)

capacity
```
public int capacity()
```

timestamp
```
public long timestamp()
```

timestamp

public MessageBatch timestamp(long ts)

increment

public MessageBatch increment(int i)

array
```
public FastArray<Message> array()
```
Returns the underlying message array. This is only intended for testing !

first
```
public <T extends Message> T first()
```

last
```
public <T extends Message> T last()
```

add

public MessageBatch add(Message msg)

add
```
public MessageBatch add(Message msg,
                        boolean resize)
```
Adds a message to the table

Parameters:

msg - the message

resize - whether or not to resize the table

Returns:

always true if resize==true, else true if the message was added or false if not

add
```
public MessageBatch add(Message msg,
                        boolean resize,
                        boolean determine_mode)
```
Adds a message to the table

Parameters:

msg - the message

resize - whether or not to resize the table

Returns:

always true if resize==true, else true if the message was added or false if not

add

public MessageBatch add(MessageBatch batch)

add
```
public MessageBatch add(MessageBatch batch,
                        boolean resize)
```
Adds another batch to this one

Parameters:

batch - the batch to add to this batch

resize - when true, this batch will be resized to accommodate the other batch

Returns:

the number of messages from the other batch that were added successfully. Will always be batch.size() unless resize is false: in this case, the number of messages that were added successfully is returned

add
```
public MessageBatch add(Message[] msgs,
                        int num_msgs)
```
Adds message to this batch from a message array

Parameters:

msgs - the message array

num_msgs - the number of messages to add, should be <= msgs.length

add

public MessageBatch add(java.util.Collection<Message> msgs)

set

public MessageBatch set(Address dest,
                        Address sender,
                        Message[] msgs)

removeIf

public MessageBatch removeIf(java.util.function.Predicate<Message> filter,
                             boolean match_all)

transferFrom
```
public int transferFrom(MessageBatch other,
                        boolean clear)
```
Transfers messages from other to this batch. Optionally clears the other batch after the transfer

Parameters:

other - the other batch

clear - If true, the transferred messages are removed from the other batch

Returns:

the number of transferred messages (may be 0 if the other batch was empty)

clear
```
public MessageBatch clear()
```

reset
```
public MessageBatch reset()
```

anyMatch

public boolean anyMatch(java.util.function.Predicate<Message> pred)

determineMode
```
public MessageBatch determineMode()
```

size
```
public int size()
```
Returns the number of non-null messages

isEmpty
```
public boolean isEmpty()
```

totalSize
```
public long totalSize()
```
Returns the size of the message batch (by calling Message.size() on all messages)

length
```
public int length()
```
Returns the total number of bytes of the message batch (by calling Message.getLength() on all messages)

resize

public MessageBatch resize(int new_capacity)

iterator
```
public java.util.Iterator<Message> iterator()
```
Iterator which iterates only over non-null messages, skipping null messages

Specified by:

iterator in interface java.lang.Iterable<Message>

iterator

public java.util.Iterator<Message> iterator(java.util.function.Predicate<Message> filter)

Iterates over all non-null message which match filter

stream

public java.util.stream.Stream<Message> stream()

stream

public java.util.stream.Stream<Message> stream(java.util.function.Predicate<Message> p)

stream

public java.util.stream.Stream<Message> stream(java.util.function.Predicate<Message> p,
                                               boolean parallel)

toString
```
public java.lang.String toString()
```
Overrides:

toString in class java.lang.Object

printHeaders

public java.lang.String printHeaders()

Class MessageBatch

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Methods inherited from interface java.lang.Iterable

Field Detail

dest

sender

cluster_name

messages

multicast

mode

timestamp

Constructor Detail

MessageBatch

MessageBatch

MessageBatch

MessageBatch

MessageBatch

Method Detail

getDest

dest

setDest

dest

getSender

sender

setSender

sender

getClusterName

clusterName

setClusterName

clusterName

cluster

isMulticast

multicast

multicast

mcast

getMode

mode

setMode

mode

capacity

timestamp

timestamp

increment

array

first

last

add

add

add

add

add

add

add

set

removeIf

transferFrom

clear

reset

anyMatch

determineMode

size

isEmpty

totalSize

length

resize

iterator

iterator

stream

stream

stream

toString

printHeaders