Package | Description |
---|---|
org.jgroups |
Provides top-level public JGroups classes such as Channel, Message, etc.
|
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.
|
Modifier and Type | Method and Description |
---|---|
void |
JChannel.up(MessageBatch batch)
Callback invoked by the protocol stack to deliver a message batch
|
Modifier and Type | Method and Description |
---|---|
void |
ForkProtocolStack.up(MessageBatch batch) |
Modifier and Type | Field and Description |
---|---|
protected MessageBatch |
TP.BatchHandler.batch |
Modifier and Type | Method and Description |
---|---|
static MessageBatch[] |
TP.readMessageBatch(DataInputStream in,
boolean multicast)
Reads a list of messages into 4 MessageBatches:
regular
OOB
INTERNAL-OOB (INTERNAL and OOB)
INTERNAL (INTERNAL)
|
Modifier and Type | Method and Description |
---|---|
protected static int |
SIZE.numHeaders(MessageBatch batch) |
protected void |
TP.passBatchUp(MessageBatch batch,
boolean perform_cluster_name_matching,
boolean discard_own_mcast) |
void |
DISCARD.up(MessageBatch batch) |
void |
DUPL.up(MessageBatch batch) |
void |
RELAY.up(MessageBatch batch) |
void |
DELAY.up(MessageBatch batch) |
void |
DAISYCHAIN.up(MessageBatch batch) |
void |
FRAG.up(MessageBatch batch) |
void |
RSVP.up(MessageBatch batch) |
void |
STATS.up(MessageBatch batch) |
void |
UNICAST3.up(MessageBatch batch) |
void |
FD.up(MessageBatch batch) |
void |
PRIO.up(MessageBatch batch) |
void |
SIZE.up(MessageBatch batch) |
void |
UNICAST.up(MessageBatch batch) |
void |
SEQUENCER.up(MessageBatch batch) |
void |
SCOPE.up(MessageBatch batch)
Deprecated.
|
void |
FD_ALL.up(MessageBatch batch) |
void |
STOMP.up(MessageBatch batch) |
void |
HDRS.up(MessageBatch batch) |
void |
AUTH.up(MessageBatch batch) |
void |
SHUFFLE.up(MessageBatch batch) |
void |
FlowControl.up(MessageBatch batch) |
void |
ENCRYPT.up(MessageBatch batch) |
void |
UNICAST2.up(MessageBatch batch) |
void |
TRACE.up(MessageBatch batch) |
void |
FORK.up(MessageBatch batch) |
void |
FRAG2.up(MessageBatch batch) |
void |
MERGE2.up(MessageBatch batch) |
void |
EXAMPLE.up(MessageBatch batch) |
void |
FC.up(MessageBatch batch)
Deprecated.
|
void |
COMPRESS.up(MessageBatch batch) |
void |
BARRIER.up(MessageBatch batch) |
Constructor and Description |
---|
BatchHandler(MessageBatch batch) |
Modifier and Type | Method and Description |
---|---|
void |
STABLE.up(MessageBatch batch) |
void |
FLUSH.up(MessageBatch batch) |
void |
NAKACK2.up(MessageBatch batch) |
Modifier and Type | Method and Description |
---|---|
void |
RELAY2.up(MessageBatch batch) |
Modifier and Type | Method and Description |
---|---|
void |
SUPERVISOR.up(MessageBatch batch) |
Modifier and Type | Method and Description |
---|---|
void |
Protocol.up(MessageBatch batch)
Sends up a multiple messages in a
MessageBatch . |
void |
ProtocolStack.up(MessageBatch batch) |
Modifier and Type | Method and Description |
---|---|
MessageBatch |
MessageBatch.add(Message msg) |
MessageBatch |
MessageBatch.clear() |
MessageBatch |
MessageBatch.clusterName(String name) |
MessageBatch |
MessageBatch.dest(Address dest) |
MessageBatch |
MessageBatch.remove(Message msg)
Removes the current message (found by indentity (==)) by nulling it in the message array
|
MessageBatch |
MessageBatch.replace(Message existing_msg,
Message new_msg)
Replaces a message in the batch with another one
|
MessageBatch |
MessageBatch.sender(Address sender) |
Modifier and Type | Method and Description |
---|---|
T |
MessageBatch.Visitor.visit(Message msg,
MessageBatch batch)
Called when iterating over the message batch
|
Copyright © 2015 JBoss, a division of Red Hat. All rights reserved.