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.demos |
Provides demonstrations of JGroups functionality.
|
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.protocols.tom | |
org.jgroups.stack |
Support for managing protocol stacks.
|
Modifier and Type | Field and Description |
---|---|
protected boolean |
Channel.discard_own_messages |
protected boolean |
JChannel.stats
Collect statistics
|
Modifier and Type | Method and Description |
---|---|
String |
JChannel.getAddressAsString() |
String |
JChannel.getAddressAsUUID() |
String |
JChannel.getClusterName() |
int |
JChannel.getNumberOfTasksInTimer() |
long |
JChannel.getReceivedBytes() |
long |
JChannel.getReceivedMessages() |
long |
JChannel.getSentBytes() |
long |
JChannel.getSentMessages() |
String |
Channel.getState() |
int |
JChannel.getTimerThreads() |
static String |
JChannel.getVersion() |
String |
JChannel.getViewAsString() |
boolean |
Channel.isClosed()
Determines whether the channel is in the closed state.
|
boolean |
JChannel.isConnected() |
boolean |
Channel.isConnected()
Determines whether the channel is connected to a group.
|
boolean |
Channel.isConnecting()
Determines whether the channel is in the connecting state; this means
Channel.connect(String) has been
called, but hasn't returned yet |
boolean |
JChannel.isOpen() |
boolean |
Channel.isOpen()
Determines whether the channel is open; ie.
|
void |
JChannel.setName(String name) |
Modifier and Type | Method and Description |
---|---|
int |
ReplCache.getClusterSize() |
String |
PartitionedHashMap.getLocalAddressAsString() |
String |
ReplCache.getLocalAddressAsString() |
int |
Cache.getSize() |
String |
PartitionedHashMap.getView() |
String |
ReplCache.getView() |
boolean |
PartitionedHashMap.isL1CacheEnabled() |
boolean |
ReplCache.isL1CacheEnabled() |
boolean |
Cache.isReapingEnabled() |
Modifier and Type | Method and Description |
---|---|
void |
JmxDemo.foobar() |
int |
JmxDemo.getAccountNumber() |
int |
JmxDemo.getMaxAge() |
static int |
JmxDemo.getMyFoo() |
String |
JmxDemo.getNumberAsString() |
static boolean |
JmxDemo.isFlag() |
void |
JmxDemo.setAccountNumber(int num) |
void |
JmxDemo.setMaxAge(int age) |
void |
JmxDemo.setMyNumber(long new_number) |
void |
JmxDemo.setNumber(int num) |
void |
JmxDemo.setOtherNumber(int num) |
Modifier and Type | Field and Description |
---|---|
protected String |
TP.channel_name
The name of the group to which this member is connected.
|
protected String |
STOMP.endpoint |
protected boolean |
FD_ALL.has_suspected_mbrs |
protected boolean |
RELAY.is_coord |
protected boolean |
CENTRAL_EXECUTOR.is_coord |
protected boolean |
Discovery.is_coord |
protected boolean |
MERGE3.is_coord |
protected boolean |
CENTRAL_LOCK.is_coord |
int |
DAISYCHAIN.msgs_forwarded |
int |
DAISYCHAIN.msgs_sent |
protected int |
RATE_LIMITER.num_blockings |
protected long |
TP.num_bytes_received |
protected long |
TP.num_bytes_sent |
protected long |
RATE_LIMITER.num_bytes_sent_in_period
Keeps track of the number of bytes sent in the current time period
|
protected int |
Discovery.num_discovery_requests |
protected int |
DISCARD.num_down |
protected int |
FD_ALL.num_heartbeats_received |
protected int |
FD_ALL.num_heartbeats_sent |
protected long |
TP.num_incoming_msgs_received |
protected int |
MERGE2.num_inconsistent_views |
protected long |
TP.num_internal_msgs_received |
protected int |
MERGE3.num_merge_events |
protected int |
MERGE2.num_merge_events |
protected int |
UNICAST2.num_messages_received |
protected int |
UNICAST2.num_messages_sent |
protected long |
TP.num_msgs_received |
protected long |
TP.num_msgs_sent |
protected long |
TP.num_oob_msgs_received |
protected int |
TP.num_rejected_msgs |
protected int |
FD_ALL.num_suspect_events |
protected int |
DISCARD.num_up |
protected AtomicLong |
UNICAST2.xmit_reqs_received |
protected AtomicLong |
UNICAST3.xmit_reqs_received |
protected AtomicLong |
UNICAST2.xmit_reqs_sent |
protected AtomicLong |
UNICAST3.xmit_reqs_sent |
protected AtomicLong |
UNICAST2.xmit_rsps_sent |
protected AtomicLong |
UNICAST3.xmit_rsps_sent |
Modifier and Type | Field and Description |
---|---|
protected AtomicBoolean |
STATE_TRANSFER.barrier_closed
Used to prevent spurious open and close barrier calls
|
protected AtomicBoolean |
StreamingStateTransfer.barrier_closed
Used to prevent spurious open and close barrier calls
|
protected long |
STABLE.num_bytes_received
The total number of bytes received from unicast and multicast messages
|
protected int |
NAKACK.num_messages_received |
protected int |
NAKACK2.num_messages_received |
protected int |
NAKACK.num_messages_sent |
protected int |
NAKACK2.num_messages_sent |
protected boolean |
STABLE.suspended
When true, don't take part in garbage collection: neither send STABLE messages nor handle STABILITY messages
|
protected AtomicLong |
NAKACK2.xmit_reqs_received |
protected AtomicLong |
NAKACK2.xmit_reqs_sent |
protected AtomicLong |
NAKACK2.xmit_rsps_received |
protected AtomicLong |
NAKACK2.xmit_rsps_sent |
Modifier and Type | Field and Description |
---|---|
protected boolean |
RELAY2.forwarding_protocol_present
Whether or not FORWARD_TO_COORD is on the stack
|
protected boolean |
RELAY2.is_site_master |
Modifier and Type | Method and Description |
---|---|
long |
RELAY2.getAvgMsgsDeliveringLocally() |
long |
RELAY2.getAvgMsgsForwardingToLocalMbr() |
long |
RELAY2.getAvgMsgsForwardingToSM() |
long |
RELAY2.getAvgMsgsRelaying() |
long |
RELAY2.getNumForwardedToLocalMbr() |
long |
RELAY2.getNumForwardedToSiteMaster() |
long |
RELAY2.getNumLocalDeliveries() |
long |
RELAY2.getNumRelayed() |
long |
RELAY2.getTimeDeliveringLocally() |
long |
RELAY2.getTimeForwardingToLocalMbr() |
long |
RELAY2.getTimeForwardingToSM() |
long |
RELAY2.getTimeRelaying() |
boolean |
RELAY2.isSiteMaster() |
Modifier and Type | Field and Description |
---|---|
protected int |
SUPERVISOR.num_event_handlers |
Modifier and Type | Method and Description |
---|---|
int |
SUPERVISOR.getNumRules() |
Modifier and Type | Method and Description |
---|---|
double |
TOA.getAvgDataMessageReceivedDuration() |
double |
TOA.getAvgFinalMessageReceivedDuration() |
double |
TOA.getAvgLastProposeMessageReceivedDuration() |
double |
TOA.getAvgNumberOfUnicastSentPerAnycast() |
double |
TOA.getAvgProposeMessageReceivedDuration() |
double |
TOA.getAvgToaSendDuration() |
int |
TOA.getNumberOfAnycastMessagesDelivered() |
int |
TOA.getNumberOfAnycastMessagesSent() |
int |
TOA.getNumberOfDataMessagesDelivered() |
int |
TOA.getNumberOfFinalAnycastSent() |
int |
TOA.getNumberOfFinalMessagesDelivered() |
int |
TOA.getNumberOfProposeMessageReceived() |
int |
TOA.getNumberOfProposeMessageSent() |
Modifier and Type | Method and Description |
---|---|
boolean |
GossipRouter.isRunning() |
boolean |
GossipRouter.isStarted() |
Copyright © 2014 JBoss, a division of Red Hat. All rights reserved.