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 receivedvoid
ReceiverAdapter. receive(MessageBatch batch)
JChannel
JChannel. up(MessageBatch batch)
Callback invoked by the protocol stack to deliver a message batchdefault 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
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 transportvoid
Protocol. up(MessageBatch batch)
Sends up a multiple messages in aMessageBatch
.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 filterMessageBatch
MessageBatch. remove(Message msg)
Removes the current message (found by indentity (==)) by nulling it in the message arrayMessageBatch
MessageBatch. replace(java.util.function.Predicate<Message> filter, Message replacement, boolean match_all)
Replaces all messages which match a given filter with a replacement messageMessageBatch
MessageBatch. replace(Message existing_msg, Message new_msg)
Replaces a message in the batch with another oneMessageBatch
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 oneprotected 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 byMaxOneThreadPerSender.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 resultsConstructors 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)
-