类 com.fr.third.jgroups.annotations.ManagedAttribute
的使用

使用ManagedAttribute的程序包

程序包	说明
com.fr.third.jgroups	Provides top-level public JGroups classes such as Channel, Message, etc.
com.fr.third.jgroups.blocks	Provides building blocks that are layered on top of channels.
com.fr.third.jgroups.demos	Provides demonstrations of JGroups functionality.
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.protocols.relay
com.fr.third.jgroups.protocols.rules
com.fr.third.jgroups.protocols.tom
com.fr.third.jgroups.stack	Support for managing protocol stacks.

com.fr.third.jgroups中ManagedAttribute的使用

注释类型为ManagedAttribute的com.fr.third.jgroups中的字段

限定符和类型	字段和说明
protected boolean	Channel.discard_own_messages
protected boolean	JChannel.stats Collect statistics

注释类型为ManagedAttribute的com.fr.third.jgroups中的方法

限定符和类型	方法和说明
java.lang.String	JChannel.getAddressAsString()
java.lang.String	JChannel.getAddressAsUUID()
java.lang.String	JChannel.getClusterName()
int	JChannel.getNumberOfTasksInTimer()
long	JChannel.getReceivedBytes()
long	JChannel.getReceivedMessages()
long	JChannel.getSentBytes()
long	JChannel.getSentMessages()
java.lang.String	Channel.getState()
int	JChannel.getTimerThreads()
static java.lang.String	JChannel.getVersion()
java.lang.String	JChannel.getViewAsString()
boolean	Channel.isClosed() Determines whether the channel is in the closed state.
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	Channel.isOpen() Determines whether the channel is open; ie. the protocol stack has been created (may not be connected though).
void	JChannel.setName(java.lang.String name)

com.fr.third.jgroups.blocks中ManagedAttribute的使用

注释类型为ManagedAttribute的com.fr.third.jgroups.blocks中的方法

限定符和类型	方法和说明
int	ReplCache.getClusterSize()
java.lang.String	ReplCache.getLocalAddressAsString()
java.lang.String	PartitionedHashMap.getLocalAddressAsString()
int	Cache.getSize()
java.lang.String	ReplCache.getView()
java.lang.String	PartitionedHashMap.getView()
boolean	ReplCache.isL1CacheEnabled()
boolean	PartitionedHashMap.isL1CacheEnabled()
boolean	Cache.isReapingEnabled()

com.fr.third.jgroups.demos中ManagedAttribute的使用

注释类型为ManagedAttribute的com.fr.third.jgroups.demos中的方法

限定符和类型	方法和说明
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)

com.fr.third.jgroups.protocols中ManagedAttribute的使用

注释类型为ManagedAttribute的com.fr.third.jgroups.protocols中的字段

限定符和类型	字段和说明
protected AsciiString	TP.cluster_name The name of the group to which this member is connected.
protected java.lang.String	STOMP.endpoint
protected boolean	FD_HOST.has_suspected_mbrs
protected boolean	FD_ALL2.has_suspected_mbrs
protected boolean	FD_ALL.has_suspected_mbrs
protected boolean	RELAY.is_coord
protected boolean	MERGE3.is_coord
protected boolean	MERGE2.is_coord 已过时。
protected boolean	Discovery.is_coord
protected boolean	CENTRAL_LOCK.is_coord
protected boolean	CENTRAL_EXECUTOR.is_coord
int	DAISYCHAIN.msgs_forwarded
int	DAISYCHAIN.msgs_sent
protected long	TP.num_batches_received
protected long	TP.num_batches_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_ALL2.num_heartbeats_received
protected int	FD_ALL.num_heartbeats_received
protected int	FD_ALL2.num_heartbeats_sent
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	FD_HOST.num_liveness_checks
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 long	TP.num_single_msgs_received
protected long	TP.num_single_msgs_sent
protected int	FD_HOST.num_suspect_events
protected int	FD_ALL2.num_suspect_events
protected int	FD_ALL.num_suspect_events
protected int	DISCARD.num_up
protected int	FILE_PING.reads
protected boolean	Discovery.transport_supports_multicasting
protected View	SHARED_LOOPBACK.view
protected int	FILE_PING.writes
protected java.util.concurrent.atomic.AtomicLong	UNICAST3.xmit_reqs_received
protected java.util.concurrent.atomic.AtomicLong	UNICAST2.xmit_reqs_received
protected java.util.concurrent.atomic.AtomicLong	UNICAST3.xmit_reqs_sent
protected java.util.concurrent.atomic.AtomicLong	UNICAST2.xmit_reqs_sent
protected java.util.concurrent.atomic.AtomicLong	UNICAST3.xmit_rsps_sent
protected java.util.concurrent.atomic.AtomicLong	UNICAST2.xmit_rsps_sent

注释类型为ManagedAttribute的com.fr.third.jgroups.protocols中的方法

限定符和类型	方法和说明
java.lang.String	Locking.getAddress()
java.lang.String	Executing.getAddress()
java.lang.String	COUNTER.getAddress()
java.lang.String	TP.ProtocolAdapter.getAddressAsString()
java.lang.String	TP.ProtocolAdapter.getAddressAsUUID()
int	UNICAST3.getAgeOutCacheSize()
int	UNICAST2.getAgeOutCacheSize()
int	UNICAST.getAgeOutCacheSize()
double	RATE_LIMITER.getAverageBlockTime()
double	UFC.getAverageTimeBlocked()
double	MFC.getAverageTimeBlocked()
double	FC.getAverageTimeBlocked() 已过时。
double	TP.getAvgBatchSize()
java.lang.String	COUNTER.getBackupCoords()
java.lang.String	CENTRAL_LOCK.getBackups()
java.lang.String	CENTRAL_EXECUTOR.getBackups()
java.lang.String	RELAY.getBridgeView()
long	SEQUENCER2.getBroadcast()
long	SEQUENCER.getBroadcast()
int	TP.getBundlerBufferSize()
java.lang.String	TP.getClusterName()
java.lang.String	TP.ProtocolAdapter.getClusterName()
java.lang.String	CENTRAL_LOCK.getCoordinator()
java.lang.String	CENTRAL_EXECUTOR.getCoordinator()
java.lang.String	MERGE2.getCurrentCoord() 已过时。
java.lang.String	Discovery.getCurrentCoord()
int	FORWARD_TO_COORD.getDeliveryTableSize()
int	TP.getDifferentClusterMessages()
int	TP.getDifferentVersionMessages()
int	UDP.getDroppedMessage()
java.lang.String	TCPPING.getDynamicHostList()
java.lang.String	STOMP.getEndpoints()
int	FORK.getForkStacks()
long	SEQUENCER.getForwarded()
int	SEQUENCER.getForwardTableSize()
int	FORWARD_TO_COORD.getForwardTableSize()
int	SEQUENCER2.getFwdQueueSize()
java.lang.String	RELAY.getGlobalView()
java.lang.String	BARRIER.getHoles()
int	BARRIER.getInFlightThreadsCount()
java.lang.String	TCPPING.getInitialHostsList()
int	TP.getInternalPoolSize()
int	TP.getInternalPoolSizeActive()
int	TP.getInternalQueueSize()
java.lang.String	UNICAST3.getLocalAddress()
java.lang.String	UNICAST2.getLocalAddress()
java.lang.String	UNICAST.getLocalAddress()
java.lang.String	TP.getLocalAddress()
java.lang.String	FD_SOCK.getLocalAddress()
java.lang.String	FD_ALL2.getLocalAddress()
java.lang.String	FD_ALL.getLocalAddress()
java.lang.String	FD.getLocalAddress()
java.lang.String	TP.getLocalPhysicalAddress()
java.lang.String	RELAY.getLocalView()
java.lang.String	UNICAST3.getMembers()
java.lang.String	UNICAST2.getMembers()
java.lang.String	UNICAST.getMembers()
java.lang.String	FD_SOCK.getMembers()
java.lang.String	FD_ALL2.getMembers()
java.lang.String	FD_ALL.getMembers()
java.lang.String	FD.getMembers()
long	UNICAST3.getNumAcksReceived()
long	UNICAST.getNumAcksReceived()
long	UNICAST3.getNumAcksSent()
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	UNICAST.getNumberOfMessagesInReceiveWindows()
int	SCOPE.getNumberOfReceiverScopes() 已过时。
int	UNICAST3.getNumConnections()
int	UNICAST2.getNumConnections()
int	UNICAST.getNumConnections()
int	STOMP.getNumConnections()
long	UNICAST3.getNumMessagesReceived()
long	UNICAST.getNumMessagesReceived()
long	UNICAST3.getNumMessagesSent()
long	UNICAST.getNumMessagesSent()
int	UNICAST3.getNumReceiveConnections()
int	UNICAST2.getNumReceiveConnections()
int	UNICAST.getNumReceiveConnections()
int	UNICAST3.getNumSendConnections()
int	UNICAST2.getNumSendConnections()
int	UNICAST.getNumSendConnections()
int	STOMP.getNumSubscriptions()
int	FD_SOCK.getNumSuspectEventsGenerated()
int	FD.getNumSuspectEventsGenerated()
static int	TP.getNumThreads()
int	TP.getNumTimerTasks()
int	UNICAST3.getNumUnackedMessages() The number of messages in all Entry.sent_msgs tables (haven't received an ACK yet)
int	UNICAST.getNumUnackedMessages() The number of messages in all Entry.sent_msgs tables (haven't received an ACK yet)
long	UNICAST3.getNumXmits()
long	UNICAST.getNumXmits()
int	TP.getOOBPoolSize()
int	TP.getOOBPoolSizeActive()
int	TP.getOOBQueueSize()
int	TCP_NIO.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()
long	SEQUENCER2.getReceivedBroadcasts()
long	SEQUENCER.getReceivedBroadcasts()
long	STATS.getReceivedBytes()
long	SEQUENCER.getReceivedForwards()
long	STATS.getReceivedMcastBytes()
long	STATS.getReceivedMcastMessages()
long	STATS.getReceivedMessages()
long	SEQUENCER2.getReceivedRequests()
long	STATS.getReceivedUnicastBytes()
long	STATS.getReceivedUnicastMessages()
int	TP.getRegularPoolSize()
int	TP.getRegularPoolSizeActive()
int	TP.getRegularQueueSize()
java.lang.String	RELAY.getRemoteView()
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_HOST.getSuspectedMembers()
java.lang.String	FD_ALL2.getSuspectedMembers()
java.lang.String	FD_ALL.getSuspectedMembers()
java.lang.String	VERIFY_SUSPECT.getSuspects()
java.lang.String	TP.getTimerClass()
int	TP.getTimerQueueSize()
int	TP.getTimerThreads()
long	RATE_LIMITER.getTotalBlockTime()
long	FC.getTotalTimeBlocked() 已过时。
short	TP.ProtocolAdapter.getTransportName()
java.lang.String	Locking.getView()
java.lang.String	Executing.getView()
java.lang.String	Discovery.getView()
java.lang.String	COUNTER.getView()
int	MERGE3.getViews()
long	UNICAST3.getXmitTableMissingMessages()
long	UNICAST2.getXmitTableMissingMessages()
long	UNICAST.getXmitTableMissingMessages()
int	UNICAST3.getXmitTableNumCompactions()
int	UNICAST2.getXmitTableNumCompactions()
int	UNICAST.getXmitTableNumCompactions()
int	UNICAST3.getXmitTableNumMoves()
int	UNICAST2.getXmitTableNumMoves()
int	UNICAST.getXmitTableNumMoves()
int	UNICAST3.getXmitTableNumPurges()
int	UNICAST2.getXmitTableNumPurges()
int	UNICAST.getXmitTableNumPurges()
int	UNICAST3.getXmitTableNumResizes()
int	UNICAST2.getXmitTableNumResizes()
int	UNICAST.getXmitTableNumResizes()
long	UNICAST3.getXmitTableUndeliveredMessages()
long	UNICAST2.getXmitTableUndeliveredMessages()
long	UNICAST.getXmitTableUndeliveredMessages()
boolean	BARRIER.isClosed()
boolean	UNICAST2.isConnectionReaperRunning()
boolean	UNICAST.isConnectionReaperRunning()
boolean	SEQUENCER2.isCoordinator()
boolean	SEQUENCER.isCoordinator()
boolean	TP.isDiagnosticsHandlerRunning()
boolean	MERGE3.isInfoSenderRunning()
boolean	TP.isLogicalAddressCacheReaperRunning()
boolean	MERGE3.isMergeTaskRunning()
boolean	MERGE2.isMergeTaskRunning() 已过时。
boolean	FD.isMonitorRunning()
boolean	FD_SOCK.isNodeCrashMonitorRunning()
boolean	BARRIER.isOpenerScheduled()
boolean	FD_HOST.isPingerRunning()
boolean	FD_ALL2.isRunning()
boolean	FD_ALL.isRunning()
boolean	MERGE3.isViewConsistencyCheckerRunning()
boolean	UNICAST3.isXmitTaskRunning()
boolean	UNICAST2.isXmitTaskRunning()
boolean	UNICAST.isXmitTaskRunning()
double	PERF.latencyInMs()
double	PERF.latencyInNs()
static java.lang.String	TP.loggerType()

com.fr.third.jgroups.protocols.pbcast中ManagedAttribute的使用

注释类型为ManagedAttribute的com.fr.third.jgroups.protocols.pbcast中的字段

限定符和类型	字段和说明
protected long	STABLE.num_bytes_received The total number of bytes received from unicast and multicast messages
protected int	NAKACK2.num_messages_received
protected int	NAKACK.num_messages_received
protected int	NAKACK2.num_messages_sent
protected int	NAKACK.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 java.util.concurrent.atomic.AtomicLong	NAKACK2.xmit_reqs_received
protected java.util.concurrent.atomic.AtomicLong	NAKACK2.xmit_reqs_sent
protected java.util.concurrent.atomic.AtomicLong	NAKACK2.xmit_rsps_received
protected java.util.concurrent.atomic.AtomicLong	NAKACK2.xmit_rsps_sent

注释类型为ManagedAttribute的com.fr.third.jgroups.protocols.pbcast中的方法

限定符和类型	方法和说明
double	FLUSH.getAverageFlushDuration()
double	StreamingStateTransfer.getAverageStateSize()
double	STATE_TRANSFER.getAverageStateSize()
int	NAKACK2.getBecomeServerQueueSizeActual()
long	NAKACK2.getCurrentSeqno()
long	NAKACK.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	NAKACK.getNonMemberMessages()
int	FLUSH.getNumberOfFlushes()
long	StreamingStateTransfer.getNumberOfStateBytesSent()
long	STATE_TRANSFER.getNumberOfStateBytesSent()
int	StreamingStateTransfer.getNumberOfStateRequests()
int	STATE_TRANSFER.getNumberOfStateRequests()
int	GMS.getNumberOfViews()
int	GMS.getNumMembers()
int	NAKACK.getPendingXmitRequests()
long	NAKACK2.getSizeOfAllMessages()
long	NAKACK.getSizeOfAllMessages()
long	NAKACK2.getSizeOfAllMessagesInclHeaders()
long	NAKACK.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	NAKACK.getXmitTableMissingMessages()
int	NAKACK2.getXmitTableNumCompactions()
int	NAKACK2.getXmitTableNumCurrentRows()
int	NAKACK2.getXmitTableNumMoves()
int	NAKACK2.getXmitTableNumPurges()
int	NAKACK2.getXmitTableNumResizes()
int	NAKACK.getXmitTableSize()
int	NAKACK2.getXmitTableUndeliveredMsgs()
boolean	GMS.isCoord()
boolean	GMS.isMergeInProgress()
boolean	GMS.isMergeKillerRunning()
boolean	GMS.isMergeTaskRunning()
boolean	GMS.isViewHandlerSuspended()
boolean	NAKACK2.isXmitTaskRunning()

com.fr.third.jgroups.protocols.relay中ManagedAttribute的使用

注释类型为ManagedAttribute的com.fr.third.jgroups.protocols.relay中的字段

限定符和类型	字段和说明
protected boolean	RELAY2.forwarding_protocol_present Whether or not FORWARD_TO_COORD is on the stack
protected boolean	RELAY2.is_site_master

注释类型为ManagedAttribute的com.fr.third.jgroups.protocols.relay中的方法

限定符和类型	方法和说明
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()

com.fr.third.jgroups.protocols.rules中ManagedAttribute的使用

注释类型为ManagedAttribute的com.fr.third.jgroups.protocols.rules中的字段

限定符和类型	字段和说明
protected int	SUPERVISOR.num_event_handlers

注释类型为ManagedAttribute的com.fr.third.jgroups.protocols.rules中的方法

限定符和类型	方法和说明
int	SUPERVISOR.getNumRules()

com.fr.third.jgroups.protocols.tom中ManagedAttribute的使用

注释类型为ManagedAttribute的com.fr.third.jgroups.protocols.tom中的方法

限定符和类型	方法和说明
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()

com.fr.third.jgroups.stack中ManagedAttribute的使用

注释类型为ManagedAttribute的com.fr.third.jgroups.stack中的方法

限定符和类型	方法和说明
boolean	GossipRouter.isRunning()
boolean	GossipRouter.isStarted()