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.stack |
Support for managing protocol stacks.
|
Modifier and Type | Field and Description |
---|---|
protected boolean |
JChannel.stats
Collect statistics
|
Modifier and Type | Method and Description |
---|---|
java.lang.String |
JChannel.getAddressAsString() |
java.lang.String |
JChannel.getAddressAsUUID() |
java.lang.String |
JChannel.getClusterName() |
int |
JChannel.getNumberOfTasksInTimer() |
int |
JChannel.getNumMessages() |
long |
JChannel.getReceivedBytes() |
long |
JChannel.getReceivedMessages() |
long |
JChannel.getSentBytes() |
long |
JChannel.getSentMessages() |
int |
JChannel.getTimerThreads() |
static java.lang.String |
JChannel.getVersion() |
java.lang.String |
JChannel.getViewAsString() |
boolean |
JChannel.isConnected()
returns true if the Connect operation has been called successfully
|
boolean |
JChannel.isOpen()
returns true if the Open operation has been called successfully
|
void |
JChannel.setName(java.lang.String name)
Sets the logical name for the channel.
|
Modifier and Type | Method and Description |
---|---|
int |
ReplCache.getClusterSize() |
java.lang.String |
PartitionedHashMap.getLocalAddressAsString() |
java.lang.String |
ReplCache.getLocalAddressAsString() |
int |
Cache.getSize() |
java.lang.String |
PartitionedHashMap.getView() |
java.lang.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() |
java.lang.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 java.lang.String |
TP.channel_name
The name of the group to which this member is connected.
|
protected java.lang.String |
STOMP.endpoint |
protected boolean |
RELAY.is_coord |
protected boolean |
CENTRAL_LOCK.is_coord |
protected boolean |
CENTRAL_EXECUTOR.is_coord |
int |
DAISYCHAIN.msgs_forwarded |
int |
DAISYCHAIN.msgs_sent |
protected int |
RATE_LIMITER.num_blockings |
protected long |
TP.num_bytes_received |
protected long |
RATE_LIMITER.num_bytes_sent
Keeps track of the number of bytes sent in the current time period
|
protected long |
TP.num_bytes_sent |
protected int |
FD_ALL.num_heartbeats_received |
protected int |
FD_ALL.num_heartbeats_sent |
protected long |
TP.num_incoming_msgs_received |
protected long |
TP.num_msgs_received |
protected long |
TP.num_msgs_sent |
protected long |
TP.num_oob_msgs_received |
protected int |
FD_ALL.num_suspect_events |
protected int |
Discovery.rank |
protected long |
RATE_LIMITER.total_block_time |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
Locking.getAddress() |
java.lang.String |
Executing.getAddress() |
java.lang.String |
TP.ProtocolAdapter.getAddressAsString() |
java.lang.String |
TP.ProtocolAdapter.getAddressAsUUID() |
int |
UNICAST2.getAgeOutCacheSize() |
int |
UNICAST.getAgeOutCacheSize() |
double |
SFC.getAverageBlockingTime()
Deprecated.
|
double |
FlowControl.getAverageTimeBlocked() |
double |
FC.getAverageTimeBlocked() |
java.lang.String |
CENTRAL_LOCK.getBackups() |
java.lang.String |
CENTRAL_EXECUTOR.getBackups() |
long |
SFC.getBlockings()
Deprecated.
|
java.lang.String |
RELAY.getBridgeView() |
long |
SEQUENCER.getBroadcast() |
int |
TP.getBundlerBufferSize() |
long |
SFC.getBytesSent()
Deprecated.
|
java.lang.String |
TP.ProtocolAdapter.getClusterName() |
java.lang.String |
CENTRAL_LOCK.getCoordinator() |
java.lang.String |
CENTRAL_EXECUTOR.getCoordinator() |
long |
SFC.getCreditRequestsReceived()
Deprecated.
|
long |
SFC.getCreditRequestsSent()
Deprecated.
|
long |
SFC.getCredits()
Deprecated.
|
java.lang.String |
TCPPING.getDynamicHostList() |
int |
DAISYCHAIN.getElementsInForwardQueue() |
int |
DAISYCHAIN.getElementsInSendQueue() |
java.lang.String |
STOMP.getEndpoints() |
long |
SEQUENCER.getForwarded() |
java.lang.String |
RELAY.getGlobalView() |
int |
BARRIER.getInFlightThreadsCount() |
java.lang.String |
TCPPING.getInitialHostsList() |
java.lang.String |
UNICAST2.getLocalAddress() |
java.lang.String |
UNICAST.getLocalAddress() |
java.lang.String |
FD_SOCK.getLocalAddress() |
java.lang.String |
FD_ALL.getLocalAddress() |
java.lang.String |
FD.getLocalAddress() |
java.lang.String |
RELAY.getLocalView() |
java.lang.String |
UNICAST2.getMembers() |
java.lang.String |
UNICAST.getMembers() |
java.lang.String |
FD_SOCK.getMembers() |
java.lang.String |
FD_ALL.getMembers() |
java.lang.String |
FD.getMembers() |
long |
UNICAST.getNumAcksReceived() |
long |
UNICAST.getNumAcksSent() |
int |
SCOPE.getNumActiveThreads() |
int |
UFC.getNumberOfBlockings() |
int |
MFC.getNumberOfBlockings() |
int |
FC.getNumberOfBlockings() |
int |
FlowControl.getNumberOfCreditRequestsReceived() |
int |
FC.getNumberOfCreditRequestsReceived() |
int |
FlowControl.getNumberOfCreditRequestsSent() |
int |
FC.getNumberOfCreditRequestsSent() |
int |
FlowControl.getNumberOfCreditResponsesReceived() |
int |
FC.getNumberOfCreditResponsesReceived() |
int |
FlowControl.getNumberOfCreditResponsesSent() |
int |
FC.getNumberOfCreditResponsesSent() |
int |
FD.getNumberOfHeartbeatsSent() |
int |
SCOPE.getNumberOfMessages() |
int |
UNICAST2.getNumberOfMessagesInReceiveWindows() |
int |
UNICAST.getNumberOfMessagesInReceiveWindows() |
int |
SCOPE.getNumberOfReceiverScopes() |
long |
UNICAST2.getNumberOfRetransmissions() |
long |
UNICAST.getNumberOfRetransmissions() |
int |
UNICAST.getNumberOfUnackedMessages()
The number of messages in all Entry.sent_msgs tables (haven't received an ACK yet)
|
long |
UNICAST2.getNumBytesReceived() |
long |
UNICAST.getNumBytesReceived() |
long |
UNICAST2.getNumBytesSent() |
long |
UNICAST.getNumBytesSent() |
int |
STOMP.getNumConnections() |
long |
UNICAST2.getNumMessagesReceived() |
long |
UNICAST.getNumMessagesReceived() |
long |
UNICAST2.getNumMessagesSent() |
long |
UNICAST.getNumMessagesSent() |
int |
STOMP.getNumSubscriptions() |
int |
FD_SOCK.getNumSuspectEventsGenerated() |
int |
FD.getNumSuspectEventsGenerated() |
int |
TP.getNumTimerTasks() |
int |
VIEW_SYNC.getNumViewsSent() |
int |
TP.getOOBPoolSize() |
int |
TP.getOOBQueueSize() |
int |
TCP_NIO.getOpenConnections() |
int |
TCP.getOpenConnections() |
java.lang.String |
FD_SOCK.getPingableMembers() |
java.lang.String |
FD.getPingableMembers() |
java.lang.String |
FD_SOCK.getPingDest() |
java.lang.String |
FD.getPingDest() |
long |
SEQUENCER.getReceivedBroadcasts() |
long |
STATS.getReceivedBytes() |
long |
SEQUENCER.getReceivedForwards() |
long |
STATS.getReceivedMcastBytes() |
long |
STATS.getReceivedMcastMessages() |
long |
STATS.getReceivedMessages() |
long |
STATS.getReceivedUnicastBytes() |
long |
STATS.getReceivedUnicastMessages() |
int |
TP.getRegularPoolSize() |
int |
TP.getRegularQueueSize() |
java.lang.String |
RELAY.getRemoteView() |
long |
SFC.getReplenishmentsReceived()
Deprecated.
|
long |
SFC.getReplenishmentsSent()
Deprecated.
|
long |
STATS.getSentBytes() |
long |
STATS.getSentMcastBytes() |
long |
STATS.getSentMcastMessages() |
long |
STATS.getSentMessages() |
long |
STATS.getSentUnicastBytes() |
long |
STATS.getSentUnicastMessages() |
java.lang.String |
STOMP.getSubscriptions() |
java.lang.String |
FD_ALL.getSuspectedMembers() |
java.lang.String |
TP.getTimerClass() |
int |
TP.getTimerQueueSize() |
int |
TP.getTimerThreads() |
long |
SFC.getTotalBlockingTime()
Deprecated.
|
long |
UFC.getTotalTimeBlocked() |
long |
MFC.getTotalTimeBlocked() |
long |
FC.getTotalTimeBlocked() |
short |
TP.ProtocolAdapter.getTransportName() |
static int |
UNICAST.getUndeliveredMessages()
Deprecated.
|
java.lang.String |
Discovery.getView() |
java.lang.String |
Locking.getView() |
java.lang.String |
Executing.getView() |
boolean |
BARRIER.isClosed() |
boolean |
SEQUENCER.isCoordinator() |
boolean |
MERGE2.isMergeTaskRunning() |
boolean |
BARRIER.isOpenerScheduled() |
boolean |
FD_ALL.isRunning() |
Modifier and Type | Method and Description |
---|---|
boolean |
GossipRouter.isRunning() |
boolean |
GossipRouter.isStarted() |
Copyright © 1998-2009 Bela Ban / Red Hat. All Rights Reserved.