| 程序包 | 说明 |
|---|---|
| com.fr.third.jgroups.protocols |
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
|
| com.fr.third.jgroups.protocols.pbcast |
Supports probabilistic broadcasts.
|
| com.fr.third.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
| 限定符和类型 | 字段和说明 |
|---|---|
protected static Filter<Message> |
UNICAST3.dont_loopback_filter |
protected static Filter<Message> |
UNICAST2.dont_loopback_filter |
protected Filter<Message> |
UNICAST3.drop_oob_and_dont_loopback_msgs_filter |
| 限定符和类型 | 字段和说明 |
|---|---|
protected static Filter<Message> |
NAKACK2.dont_loopback_filter |
protected Filter<Message> |
NAKACK2.no_dummy_and_no_oob_delivered_msgs_and_no_dont_loopback_msgs |
| 限定符和类型 | 字段和说明 |
|---|---|
protected Filter<T> |
Table.Remover.filter |
protected Filter<T> |
Table.RemoverOnAdd.filter |
| 限定符和类型 | 方法和说明 |
|---|---|
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
|
| 构造器和说明 |
|---|
MessageBatch(Address dest,
Address sender,
AsciiString cluster_name,
boolean multicast,
java.util.Collection<Message> msgs,
Filter<Message> filter) |
Table.Remover(boolean nullify,
int max_results,
Filter<T> filter) |
Table.RemoverOnAdd(Filter<T> remover) |