Package org.apache.cassandra.net

Class MessagingServiceMBeanImpl

java.lang.Object

org.apache.cassandra.net.MessagingServiceMBeanImpl

All Implemented Interfaces:

MessagingServiceMBean

Direct Known Subclasses:

MessagingService

public class MessagingServiceMBeanImpl
extends Object
implements MessagingServiceMBean

Field Summary

Fields

Modifier and Type	Field	Description
final ConcurrentMap<InetAddressAndPort,OutboundConnections>	channelManagers
static final String	MBEAN_NAME
final ConcurrentMap<InetAddressAndPort,InboundMessageHandlers>	messageHandlers
final MessagingMetrics	metrics
final EndpointMessagingVersions	versions

Constructor Summary

Constructors

Constructor	Description
MessagingServiceMBeanImpl(boolean testOnly, EndpointMessagingVersions versions, MessagingMetrics metrics)

Method Summary

Modifier and Type	Method	Description
Map<String,Double>	getBackPressurePerHost()	Back-pressure rate limiting per host
Map<String,Integer>	getDroppedMessages()	dropped message counts for server lifetime
Map<String,Long>	getGossipMessageCompletedTasks()	Completed tasks for gossip message TCP Connections
Map<String,Long>	getGossipMessageCompletedTasksWithPort()
Map<String,Long>	getGossipMessageDroppedTasks()	Dropped tasks for gossip message TCP Connections
Map<String,Long>	getGossipMessageDroppedTasksWithPort()
Map<String,Integer>	getGossipMessagePendingTasks()	Pending tasks for gossip message TCP Connections
Map<String,Integer>	getGossipMessagePendingTasksWithPort()
Map<String,Long>	getLargeMessageCompletedTasks()	Completed tasks for large message) TCP Connections
Map<String,Long>	getLargeMessageCompletedTasksWithPort()
Map<String,Long>	getLargeMessageDroppedTasks()	Dropped tasks for large message TCP Connections
Map<String,Long>	getLargeMessageDroppedTasksWithPort()
Map<String,Integer>	getLargeMessagePendingTasks()	Pending tasks for large message TCP Connections
Map<String,Integer>	getLargeMessagePendingTasksWithPort()
Map<String,Long>	getSmallMessageCompletedTasks()	Completed tasks for small message TCP Connections
Map<String,Long>	getSmallMessageCompletedTasksWithPort()
Map<String,Long>	getSmallMessageDroppedTasks()	Dropped tasks for small message TCP Connections
Map<String,Long>	getSmallMessageDroppedTasksWithPort()
Map<String,Integer>	getSmallMessagePendingTasks()	Pending tasks for small message TCP Connections
Map<String,Integer>	getSmallMessagePendingTasksWithPort()
Map<String,Long>	getTimeoutsPerHost()	Number of timeouts per host
Map<String,Long>	getTimeoutsPerHostWithPort()
long	getTotalTimeouts()	Total number of timeouts happened on this node
int	getVersion(String address)
boolean	isBackPressureEnabled()	Get back-pressure enabled state
void	reloadSslCertificates()
void	setBackPressureEnabled(boolean enabled)	Enable/Disable back-pressure

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

MBEAN_NAME

public static final String MBEAN_NAME

See Also:

• Constant Field Values

channelManagers

public final ConcurrentMap<InetAddressAndPort,OutboundConnections> channelManagers

messageHandlers

public final ConcurrentMap<InetAddressAndPort,InboundMessageHandlers> messageHandlers

versions

public final EndpointMessagingVersions versions

metrics

public final MessagingMetrics metrics

Constructor Details

MessagingServiceMBeanImpl

public MessagingServiceMBeanImpl(boolean testOnly,
 EndpointMessagingVersions versions,
 MessagingMetrics metrics)

Method Details

getLargeMessagePendingTasks

public Map<String,Integer> getLargeMessagePendingTasks()

Description copied from interface: MessagingServiceMBean

Pending tasks for large message TCP Connections

Specified by:

getLargeMessagePendingTasks in interface MessagingServiceMBean

getLargeMessageCompletedTasks

public Map<String,Long> getLargeMessageCompletedTasks()

Description copied from interface: MessagingServiceMBean

Completed tasks for large message) TCP Connections

Specified by:

getLargeMessageCompletedTasks in interface MessagingServiceMBean

getLargeMessageDroppedTasks

public Map<String,Long> getLargeMessageDroppedTasks()

Description copied from interface: MessagingServiceMBean

Dropped tasks for large message TCP Connections

Specified by:

getLargeMessageDroppedTasks in interface MessagingServiceMBean

getSmallMessagePendingTasks

public Map<String,Integer> getSmallMessagePendingTasks()

Description copied from interface: MessagingServiceMBean

Pending tasks for small message TCP Connections

Specified by:

getSmallMessagePendingTasks in interface MessagingServiceMBean

getSmallMessageCompletedTasks

public Map<String,Long> getSmallMessageCompletedTasks()

Description copied from interface: MessagingServiceMBean

Completed tasks for small message TCP Connections

Specified by:

getSmallMessageCompletedTasks in interface MessagingServiceMBean

getSmallMessageDroppedTasks

public Map<String,Long> getSmallMessageDroppedTasks()

Description copied from interface: MessagingServiceMBean

Dropped tasks for small message TCP Connections

Specified by:

getSmallMessageDroppedTasks in interface MessagingServiceMBean

getGossipMessagePendingTasks

public Map<String,Integer> getGossipMessagePendingTasks()

Description copied from interface: MessagingServiceMBean

Pending tasks for gossip message TCP Connections

Specified by:

getGossipMessagePendingTasks in interface MessagingServiceMBean

getGossipMessageCompletedTasks

public Map<String,Long> getGossipMessageCompletedTasks()

Description copied from interface: MessagingServiceMBean

Completed tasks for gossip message TCP Connections

Specified by:

getGossipMessageCompletedTasks in interface MessagingServiceMBean

getGossipMessageDroppedTasks

public Map<String,Long> getGossipMessageDroppedTasks()

Description copied from interface: MessagingServiceMBean

Dropped tasks for gossip message TCP Connections

Specified by:

getGossipMessageDroppedTasks in interface MessagingServiceMBean

getLargeMessagePendingTasksWithPort

public Map<String,Integer> getLargeMessagePendingTasksWithPort()

Specified by:

getLargeMessagePendingTasksWithPort in interface MessagingServiceMBean

getLargeMessageCompletedTasksWithPort

public Map<String,Long> getLargeMessageCompletedTasksWithPort()

Specified by:

getLargeMessageCompletedTasksWithPort in interface MessagingServiceMBean

getLargeMessageDroppedTasksWithPort

public Map<String,Long> getLargeMessageDroppedTasksWithPort()

Specified by:

getLargeMessageDroppedTasksWithPort in interface MessagingServiceMBean

getSmallMessagePendingTasksWithPort

public Map<String,Integer> getSmallMessagePendingTasksWithPort()

Specified by:

getSmallMessagePendingTasksWithPort in interface MessagingServiceMBean

getSmallMessageCompletedTasksWithPort

public Map<String,Long> getSmallMessageCompletedTasksWithPort()

Specified by:

getSmallMessageCompletedTasksWithPort in interface MessagingServiceMBean

getSmallMessageDroppedTasksWithPort

public Map<String,Long> getSmallMessageDroppedTasksWithPort()

Specified by:

getSmallMessageDroppedTasksWithPort in interface MessagingServiceMBean

getGossipMessagePendingTasksWithPort

public Map<String,Integer> getGossipMessagePendingTasksWithPort()

Specified by:

getGossipMessagePendingTasksWithPort in interface MessagingServiceMBean

getGossipMessageCompletedTasksWithPort

public Map<String,Long> getGossipMessageCompletedTasksWithPort()

Specified by:

getGossipMessageCompletedTasksWithPort in interface MessagingServiceMBean

getGossipMessageDroppedTasksWithPort

public Map<String,Long> getGossipMessageDroppedTasksWithPort()

Specified by:

getGossipMessageDroppedTasksWithPort in interface MessagingServiceMBean

getDroppedMessages

public Map<String,Integer> getDroppedMessages()

Description copied from interface: MessagingServiceMBean

dropped message counts for server lifetime

Specified by:

getDroppedMessages in interface MessagingServiceMBean

getTotalTimeouts

public long getTotalTimeouts()

Description copied from interface: MessagingServiceMBean

Total number of timeouts happened on this node

Specified by:

getTotalTimeouts in interface MessagingServiceMBean

getTimeoutsPerHost

public Map<String,Long> getTimeoutsPerHost()

Description copied from interface: MessagingServiceMBean

Number of timeouts per host

Specified by:

getTimeoutsPerHost in interface MessagingServiceMBean

getTimeoutsPerHostWithPort

public Map<String,Long> getTimeoutsPerHostWithPort()

Specified by:

getTimeoutsPerHostWithPort in interface MessagingServiceMBean

getBackPressurePerHost

public Map<String,Double> getBackPressurePerHost()

Description copied from interface: MessagingServiceMBean

Back-pressure rate limiting per host

Specified by:

getBackPressurePerHost in interface MessagingServiceMBean

setBackPressureEnabled

public void setBackPressureEnabled(boolean enabled)

Description copied from interface: MessagingServiceMBean

Enable/Disable back-pressure

Specified by:

setBackPressureEnabled in interface MessagingServiceMBean

isBackPressureEnabled

public boolean isBackPressureEnabled()

Description copied from interface: MessagingServiceMBean

Get back-pressure enabled state

Specified by:

isBackPressureEnabled in interface MessagingServiceMBean

reloadSslCertificates

public void reloadSslCertificates()

Specified by:

reloadSslCertificates in interface MessagingServiceMBean

getVersion

public int getVersion(String address)
               throws UnknownHostException

Specified by:

getVersion in interface MessagingServiceMBean

Throws:

UnknownHostException