Package | Description |
---|---|
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.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
Modifier and Type | Field and Description |
---|---|
protected static Filter<Message> |
UNICAST3.dont_loopback_filter |
protected static Filter<Message> |
UNICAST2.dont_loopback_filter
Deprecated.
|
protected Filter<Message> |
UNICAST3.drop_oob_and_dont_loopback_msgs_filter |
Modifier and Type | Field and Description |
---|---|
protected static Filter<Message> |
NAKACK2.dont_loopback_filter |
protected Filter<Message> |
NAKACK2.no_dummy_and_no_oob_delivered_msgs_and_no_dont_loopback_msgs |
Modifier and Type | Field and Description |
---|---|
protected Filter<T> |
Table.Remover.filter |
protected Filter<T> |
Table.RemoverOnAdd.filter |
Modifier and Type | Method and Description |
---|---|
protected boolean |
Table._add(long seqno,
T element,
boolean check_if_resize_needed,
Filter<T> remove_filter) |
boolean |
Table.add(long seqno,
T element,
Filter<T> remove_filter)
Adds an element if the element at the given index is null.
|
MessageBatch |
MessageBatch.remove(Filter<Message> filter)
Removes all messages which match filter
|
java.util.List<T> |
Table.removeMany(java.util.concurrent.atomic.AtomicBoolean processing,
boolean nullify,
int max_results,
Filter<T> filter)
Removes between 0 and max_results elements from the table and returns them in a list.
|
MessageBatch |
MessageBatch.replace(Filter<Message> filter,
Message replacement,
boolean match_all)
Replaces all messages which match a given filter with a replacement message
|
Constructor and Description |
---|
MessageBatch(Address dest,
Address sender,
AsciiString cluster_name,
boolean multicast,
java.util.Collection<Message> msgs,
Filter<Message> filter) |
Remover(boolean nullify,
int max_results,
Filter<T> filter) |
RemoverOnAdd(Filter<T> remover) |
Copyright © 1998-2020 Red Hat. All Rights Reserved.