Uses of Class
org.jgroups.annotations.ManagedAttribute
-
Packages that use ManagedAttribute 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.blocks.cs This package contains all client-server related interfaces and classesorg.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 org.jgroups.protocols.relay org.jgroups.protocols.rules org.jgroups.protocols.tom org.jgroups.stack Support for managing protocol stacks. -
-
Uses of ManagedAttribute in org.jgroups
Fields in org.jgroups with annotations of type ManagedAttribute Modifier and Type Field Description protected boolean
JChannel. discard_own_messages
protected boolean
JChannel. stats
Methods in org.jgroups with annotations of type ManagedAttribute Modifier and Type Method Description java.lang.String
JChannel. getAddressAsString()
java.lang.String
JChannel. getAddressAsUUID()
java.lang.String
JChannel. getClusterName()
long
JChannel. getReceivedBytes()
long
JChannel. getReceivedMessages()
long
JChannel. getSentBytes()
long
JChannel. getSentMessages()
java.lang.String
Channel. getState()
Deprecated.java.lang.String
JChannel. getState()
static java.lang.String
JChannel. getVersion()
java.lang.String
JChannel. getViewAsString()
boolean
Channel. isClosed()
Deprecated.Determines whether the channel is in the closed state.boolean
JChannel. isClosed()
boolean
Channel. isConnected()
Deprecated.Determines whether the channel is connected to a group.boolean
JChannel. isConnected()
boolean
Channel. isConnecting()
Deprecated.Determines whether the channel is in the connecting state; this meansChannel.connect(String)
has been called, but hasn't returned yetboolean
JChannel. isConnecting()
boolean
Channel. isOpen()
Deprecated.Determines whether the channel is open; ie.boolean
JChannel. isOpen()
JChannel
JChannel. setName(java.lang.String name)
Sets the logical name for the channel. -
Uses of ManagedAttribute in org.jgroups.blocks
Methods in org.jgroups.blocks with annotations of type ManagedAttribute Modifier and Type Method 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()
-
Uses of ManagedAttribute in org.jgroups.blocks.cs
Fields in org.jgroups.blocks.cs with annotations of type ManagedAttribute Modifier and Type Field Description protected long
BaseServer. conn_expire_time
protected int
BaseServer. max_length
protected int
NioBaseServer. max_send_buffers
protected int
NioBaseServer. num_selects
protected int
BaseServer. recv_buf_size
protected int
BaseServer. send_buf_size
protected boolean
BaseServer. use_peer_connections
Methods in org.jgroups.blocks.cs with annotations of type ManagedAttribute Modifier and Type Method Description int
BaseServer. getNumConnections()
int
BaseServer. getNumOpenConnections()
boolean
BaseServer. running()
-
Uses of ManagedAttribute in org.jgroups.demos
Methods in org.jgroups.demos with annotations of type ManagedAttribute Modifier and Type Method 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)
-
Uses of ManagedAttribute in org.jgroups.protocols
Fields in org.jgroups.protocols with annotations of type ManagedAttribute Modifier and Type Field Description protected boolean
SEQUENCER. ack_mode
When ack_mode is set, we need to wait for an ack for each forwarded message until we can send the next oneprotected AverageMinMax
TransferQueueBundler. avg_fill_count
protected double
RED. avg_queue_size
protected long
SEQUENCER. bcast_msgs
protected long
SEQUENCER2. bcasts_delivered
protected long
SEQUENCER2. bcasts_received
protected long
SEQUENCER2. bcasts_sent
protected AsciiString
TP. cluster_name
The name of the group to which this member is connected.protected View
SHARED_LOOPBACK. curr_view
protected long
SEQUENCER. delivered_bcasts
protected java.lang.String
STOMP. endpoint
protected long
SEQUENCER. forwarded_msgs
protected boolean
RSVP. handle_unicasts
protected boolean
FailureDetection. has_suspected_mbrs
protected boolean
FD_HOST. has_suspected_mbrs
protected boolean
TCPPING. initial_hosts_set_programmatically
protected boolean
CENTRAL_EXECUTOR. is_coord
protected boolean
CENTRAL_LOCK. is_coord
protected boolean
Discovery. is_coord
protected boolean
MERGE3. is_coord
protected boolean
RELAY. is_coord
Deprecated.protected boolean
SEQUENCER. is_coord
protected boolean
TP. is_trace
protected boolean
UNICAST3. is_trace
int
DAISYCHAIN. msgs_forwarded
int
DAISYCHAIN. msgs_sent
protected int
SEQUENCER. num_acks
protected int
FD_ALL3. num_bits
protected int
RATE_LIMITER. num_blockings
protected long
RATE_LIMITER. num_bytes_sent_in_period
Keeps track of the number of bytes sent in the current time periodprotected int
Discovery. num_discovery_requests
protected int
DISCARD. num_down
protected long
TransferQueueBundler. num_drops_on_full_queue
protected java.util.concurrent.atomic.LongAdder
FRAG2. num_frags_received
protected java.util.concurrent.atomic.LongAdder
FRAG3. num_frags_received
protected java.util.concurrent.atomic.LongAdder
FRAG2. num_frags_sent
protected java.util.concurrent.atomic.LongAdder
FRAG3. num_frags_sent
protected int
FailureDetection. num_heartbeats_received
protected int
FailureDetection. num_heartbeats_sent
protected int
FD_HOST. num_liveness_checks
protected int
MERGE3. num_merge_events
protected int
REVERSE. num_msgs_to_reverse
protected long
TransferQueueBundler. num_sends_because_full_queue
protected long
TransferQueueBundler. num_sends_because_no_msgs
protected int
FailureDetection. num_suspect_events
protected int
FD_HOST. num_suspect_events
protected int
DISCARD. num_up
protected int
RED. queue_capacity
protected int
FILE_PING. reads
protected long
SEQUENCER. received_bcasts
protected long
SEQUENCER. received_forwards
protected long
SEQUENCER2. received_requests
protected long
SEQUENCER2. received_responses
protected long
SEQUENCER2. request_msgs
protected long
SEQUENCER2. response_msgs
protected boolean
Discovery. sends_can_block
protected boolean
UNICAST3. sends_can_block
protected long
SEQUENCER2. sent_requests
protected long
SEQUENCER2. sent_responses
protected boolean
TP. timer_handle_non_blocking_tasks
protected boolean
Discovery. transport_supports_multicasting
protected java.util.Collection<java.lang.String>
TCPPING. unresolved_hosts
protected int
FILE_PING. writes
protected java.util.concurrent.atomic.LongAdder
UNICAST3. xmit_reqs_received
protected java.util.concurrent.atomic.LongAdder
UNICAST3. xmit_reqs_sent
protected java.util.concurrent.atomic.LongAdder
UNICAST3. xmit_rsps_sent
Methods in org.jgroups.protocols with annotations of type ManagedAttribute Modifier and Type Method Description int
TP. bundlerNumSpins()
<T extends TP>
TTP. bundlerNumSpins(int spins)
java.lang.String
TP. bundlerStats()
java.lang.String
TP. bundlerWaitStrategy()
<T extends TP>
TTP. bundlerWaitStrategy(java.lang.String strategy)
java.lang.String
RATE. currentReceiveRate()
java.lang.String
RATE. currentSendRate()
java.lang.String
COUNTER. getAddress()
java.lang.String
Executing. getAddress()
java.lang.String
Locking. getAddress()
int
UNICAST3. getAgeOutCacheSize()
double
RATE_LIMITER. getAverageBlockTime()
double
MFC. getAverageTimeBlocked()
double
UFC. getAverageTimeBlocked()
java.lang.String
UNICAST3. getAvgBatchDeliverySize()
java.lang.String
TP. getAvgBatchSize()
double
DELIVERY_TIME. getAvgDeliveryTime()
java.lang.String
FRAG2. getAvgSizeDown()
java.lang.String
FRAG3. getAvgSizeDown()
java.lang.String
FRAG2. getAvgSizeUp()
java.lang.String
FRAG3. getAvgSizeUp()
java.lang.String
COUNTER. getBackupCoords()
java.lang.String
CENTRAL_EXECUTOR. getBackups()
java.lang.String
CENTRAL_LOCK. getBackups()
java.lang.String
RELAY. getBridgeView()
Deprecated.int
TP. getBundlerBufferSize()
java.lang.String
TP. getBundlerClass()
int
FD_SOCK. getClientBindPortActual()
java.lang.String
TP. getClusterName()
java.lang.String
CENTRAL_EXECUTOR. getCoordinator()
java.lang.String
CENTRAL_LOCK. getCoordinator()
java.lang.String
CENTRAL_LOCK2. getCoordinator()
java.lang.String
Discovery. getCurrentCoord()
int
FORWARD_TO_COORD. getDeliveryTableSize()
int
TP. getDifferentClusterMessages()
int
TP. getDifferentVersionMessages()
static int
LOCAL_PING. getDiscoveryCacheSize()
java.lang.String
MULTI_PING. getDiscoveryProtocols()
long
RED. getDroppedMessages()
int
UDP. getDroppedMessages()
double
RED. getDropRate()
java.lang.String
TCPPING. getDynamicHostList()
java.lang.String
STOMP. getEndpoints()
int
FORK. getForkStacks()
int
FORWARD_TO_COORD. getForwardTableSize()
int
SEQUENCER. getForwardTableSize()
int
SEQUENCER2. getFwdQueueSize()
java.lang.String
RELAY. getGlobalView()
Deprecated.java.lang.String
BARRIER. getHoles()
java.lang.String
DISCARD. getIgnoredMembers()
int
BARRIER. getInFlightThreadsCount()
int
TP. getInternalThreadPoolSize()
int
TP. getInternalThreadPoolSizeLargest()
java.lang.String
ASYM_ENCRYPT. getKeyServerAddress()
java.lang.String
FailureDetection. getLocalAddress()
java.lang.String
FD_SOCK. getLocalAddress()
java.lang.String
FD. getLocalAddress()
java.lang.String
TP. getLocalAddress()
java.lang.String
UNICAST3. getLocalAddress()
java.lang.String
TP. getLocalPhysicalAddress()
java.lang.String
RELAY. getLocalView()
Deprecated.java.lang.String
FailureDetection. getMembers()
java.lang.String
FD_SOCK. getMembers()
java.lang.String
FD. getMembers()
long
UNICAST3. getNumAcksReceived()
long
UNICAST3. getNumAcksSent()
long
MsgStats. getNumBatchesReceived()
long
MsgStats. getNumBatchesSent()
int
MFC. getNumberOfBlockings()
int
UFC. getNumberOfBlockings()
int
FlowControl. getNumberOfCreditRequestsReceived()
int
FlowControl. getNumberOfCreditRequestsSent()
int
FlowControl. getNumberOfCreditResponsesReceived()
int
FlowControl. getNumberOfCreditResponsesSent()
int
FD. getNumberOfHeartbeatsSent()
int
MFC_NB. getNumberOfQueuedMessages()
int
UFC_NB. getNumberOfQueuedMessages()
int
MFC_NB. getNumberOfQueuings()
int
UFC_NB. getNumberOfQueuings()
int
TP. getNumberOfThreadDumps()
long
MsgStats. getNumBytesReceived()
long
MsgStats. getNumBytesSent()
int
Locking. getNumClientLocks()
int
STOMP. getNumConnections()
int
UNICAST3. getNumConnections()
long
MsgStats. getNumInternalMsgsReceived()
long
UNICAST3. getNumMessagesReceived()
long
UNICAST3. getNumMessagesSent()
long
MsgStats. getNumMsgsReceived()
long
MsgStats. getNumMsgsSent()
long
MsgStats. getNumOOBMsgsReceived()
int
UNICAST3. getNumReceiveConnections()
int
MsgStats. getNumRejectedMsgs()
int
UNICAST3. getNumSendConnections()
int
Locking. getNumServerLocks()
long
MsgStats. getNumSingleMsgsSent()
int
STOMP. getNumSubscriptions()
int
FD_SOCK. getNumSuspectedMembers()
int
FD_SOCK. getNumSuspectEventsGenerated()
int
FD. getNumSuspectEventsGenerated()
static int
TP. getNumThreads()
int
MsgStats. getNumThreadsSpawned()
int
TP. getNumTimerTasks()
int
UNICAST3. getNumUnackedMessages()
The number of messages in all Entry.sent_msgs tables (haven't received an ACK yet)long
UNICAST3. getNumXmits()
int
TCP_NIO2. getOpenConnections()
int
TCP. getOpenConnections()
int
RSVP. getPendingRsvpRequests()
java.lang.String
FD_SOCK. getPingableMembers()
java.lang.String
FD. getPingableMembers()
java.lang.String
FD_SOCK. getPingDest()
java.lang.String
FD. getPingDest()
java.lang.String
ASYM_ENCRYPT. getPublicKeys()
int
MFC_NB. getQueuedSize()
int
UFC_NB. getQueuedSize()
long
STATS. getReceivedBytes()
long
STATS. getReceivedMcastBytes()
long
STATS. getReceivedMcastMessages()
long
STATS. getReceivedMessages()
long
STATS. getReceivedUnicastBytes()
long
STATS. getReceivedUnicastMessages()
java.lang.String
RELAY. getRemoteView()
Deprecated.java.util.Collection<PhysicalAddress>
TCPPING. getResolvedHosts()
long
UFC. getSenderCreditsFor(Address mbr)
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
FailureDetection. getSuspectedMembers()
java.lang.String
FD_HOST. getSuspectedMembers()
java.lang.String
FD_SOCK. getSuspectedMembers()
java.lang.String
VERIFY_SUSPECT. getSuspects()
int
TP. getThreadPoolSize()
int
TP. getThreadPoolSizeActive()
int
TP. getThreadPoolSizeLargest()
java.lang.String
TP. getTimerClass()
int
TP. getTimerThreads()
int
UNICAST3. getTimestamper()
long
RATE_LIMITER. getTotalBlockTime()
long
RED. getTotalMessages()
java.lang.String
COUNTER. getView()
java.lang.String
Discovery. getView()
java.lang.String
Executing. getView()
java.lang.String
Locking. getView()
int
MERGE3. getViews()
int
UNICAST3. getXmitTableDeliverableMessages()
int
UNICAST3. getXmitTableMissingMessages()
int
UNICAST3. getXmitTableNumCompactions()
int
UNICAST3. getXmitTableNumMoves()
int
UNICAST3. getXmitTableNumPurges()
int
UNICAST3. getXmitTableNumResizes()
int
UNICAST3. getXmitTableUndeliveredMessages()
java.lang.String
RATE. highestReceiveRate()
java.lang.String
RATE. highestSendRate()
boolean
TCP_NIO2. isAcceptorRunning()
boolean
BARRIER. isClosed()
boolean
CENTRAL_LOCK2. isCoord()
boolean
SEQUENCER. isCoordinator()
boolean
SEQUENCER2. isCoordinator()
boolean
TP. isDiagnosticsRunning()
boolean
FailureDetection. isHeartbeatSenderRunning()
boolean
MERGE3. isInfoSenderRunning()
boolean
FILE_PING. isInfoWriterRunning()
boolean
ASYM_ENCRYPT. isKeyServer()
boolean
TP. isLogicalAddressCacheReaperRunning()
boolean
FD_SOCK. isLogSuspectedMessages()
boolean
MERGE3. isMergeTaskRunning()
boolean
FD. isMonitorRunning()
boolean
FD_SOCK. isNodeCrashMonitorRunning()
boolean
BARRIER. isOpenerScheduled()
boolean
FD_HOST. isPingerRunning()
boolean
MFC_NB. isQueuing()
boolean
CENTRAL_LOCK2. isRequestHandlerRunning()
protected boolean
RSVP. isResendTaskRunning()
boolean
FailureDetection. isRunning()
boolean
TCP_NIO2. isSelectorOpen()
boolean
FailureDetection. isTimeoutCheckerRunning()
boolean
MERGE3. isViewConsistencyCheckerRunning()
boolean
UNICAST3. isXmitTaskRunning()
double
PERF. latencyInMs()
double
PERF. latencyInNs()
static java.lang.String
TP. loggerType()
int
TCP_NIO2. numPartialWrites()
int
TCP_NIO2. numSelects()
int
REVERSE. queuedMessages()
void
TCP_NIO2. readerIdleTime(long t)
int
CENTRAL_LOCK2. requestQueueSize()
java.lang.String
RemoveQueueBundler. rqbAvgBatchSize()
int
RemoveQueueBundler. rqbRemoveQueueSize()
void
RemoveQueueBundler. rqbRemoveQueueSize(int size)
int
RemoveQueueBundler. rqbRingBufferSize()
java.lang.String
Encrypt. version()
-
Uses of ManagedAttribute in org.jgroups.protocols.pbcast
Fields in org.jgroups.protocols.pbcast with annotations of type ManagedAttribute Modifier and Type Field Description protected Address
STABLE. coordinator
protected boolean
NAKACK2. is_trace
protected long
STABLE. num_bytes_received
The total number of bytes received from unicast and multicast messagesprotected int
NAKACK2. num_messages_received
protected int
NAKACK2. num_messages_sent
protected boolean
NAKACK2. sends_can_block
protected boolean
STABLE. suspended
When true, don't take part in garbage collection: neither send STABLE messages nor handle STABILITY messagesprotected java.util.concurrent.atomic.LongAdder
NAKACK2. xmit_reqs_received
protected java.util.concurrent.atomic.LongAdder
NAKACK2. xmit_reqs_sent
protected java.util.concurrent.atomic.LongAdder
NAKACK2. xmit_rsps_received
protected java.util.concurrent.atomic.LongAdder
NAKACK2. xmit_rsps_sent
Methods in org.jgroups.protocols.pbcast with annotations of type ManagedAttribute Modifier and Type Method Description double
FLUSH. getAverageFlushDuration()
double
STATE_TRANSFER. getAverageStateSize()
double
StreamingStateTransfer. getAverageStateSize()
int
NAKACK2. getBecomeServerQueueSizeActual()
long
NAKACK2. getCurrentSeqno()
java.lang.String
GMS. getImplementation()
java.lang.String
GMS. getLocalAddress()
java.lang.String
GMS. getMembers()
java.lang.String
GMS. getMergeId()
int
NAKACK2. getNonMemberMessages()
int
FLUSH. getNumberOfFlushes()
long
STATE_TRANSFER. getNumberOfStateBytesSent()
long
StreamingStateTransfer. getNumberOfStateBytesSent()
long
STATE_TRANSFER. getNumberOfStateRequests()
long
StreamingStateTransfer. getNumberOfStateRequests()
int
GMS. getNumberOfViews()
int
GMS. getNumMembers()
int
STABLE. getNumVotes()
long
NAKACK2. getSizeOfAllMessages()
long
NAKACK2. getSizeOfAllMessagesInclHeaders()
int
STABLE. getStabilityReceived()
int
STABLE. getStabilitySent()
int
STABLE. getStableReceived()
int
STABLE. getStableSent()
boolean
STABLE. getStableTaskRunning()
long
StreamingStateTransfer. getThreadPoolCompletedTasks()
int
StreamingStateTransfer. getThreadPoolSize()
long
FLUSH. getTotalTimeInFlush()
java.lang.String
GMS. getView()
int
GMS. getViewHandlerSize()
long
NAKACK2. getXmitTableCapacity()
int
NAKACK2. getXmitTableMissingMessages()
int
NAKACK2. getXmitTableNumCompactions()
int
NAKACK2. getXmitTableNumCurrentRows()
int
NAKACK2. getXmitTableNumMoves()
int
NAKACK2. getXmitTableNumPurges()
int
NAKACK2. getXmitTableNumResizes()
int
NAKACK2. getXmitTableUndeliveredMsgs()
boolean
GMS. isCoord()
boolean
GMS. isLeaving()
boolean
GMS. isMergeInProgress()
boolean
GMS. isMergeKillerRunning()
boolean
GMS. isMergeTaskRunning()
boolean
GMS. isViewHandlerSuspended()
boolean
NAKACK2. isXmitTaskRunning()
boolean
NAKACK2. resendTaskRunning()
void
NAKACK2. setResendLastSeqno(boolean flag)
-
Uses of ManagedAttribute in org.jgroups.protocols.relay
Fields in org.jgroups.protocols.relay with annotations of type ManagedAttribute Modifier and Type Field Description protected boolean
RELAY2. broadcast_route_notifications
protected boolean
RELAY2. forwarding_protocol_present
Whether or not FORWARD_TO_COORD is on the stackprotected boolean
RELAY2. is_site_master
protected java.util.List<Address>
RELAY2. site_masters
Methods in org.jgroups.protocols.relay with annotations of type ManagedAttribute Modifier and Type Method Description long
RELAY2. getAvgMsgsDeliveringLocally()
long
RELAY2. getAvgMsgsForwardingToLocalMbr()
long
RELAY2. getAvgMsgsForwardingToSM()
long
RELAY2. getAvgMsgsRelaying()
int
RELAY2. getNumberOfNoRouteErrors()
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()
-
Uses of ManagedAttribute in org.jgroups.protocols.rules
Fields in org.jgroups.protocols.rules with annotations of type ManagedAttribute Modifier and Type Field Description protected int
SUPERVISOR. num_event_handlers
Deprecated.Methods in org.jgroups.protocols.rules with annotations of type ManagedAttribute Modifier and Type Method Description int
SUPERVISOR. getNumRules()
Deprecated. -
Uses of ManagedAttribute in org.jgroups.protocols.tom
Methods in org.jgroups.protocols.tom with annotations of type ManagedAttribute Modifier and Type Method 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()
-
Uses of ManagedAttribute in org.jgroups.stack
Fields in org.jgroups.stack with annotations of type ManagedAttribute Modifier and Type Field Description protected long
GossipRouter. expiry_time
protected int
GossipRouter. port
Methods in org.jgroups.stack with annotations of type ManagedAttribute Modifier and Type Method Description boolean
GossipRouter. running()
-