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 java.lang.Object
implements MessagingServiceMBean

Field Summary

Fields

Modifier and Type	Field	Description
java.util.concurrent.ConcurrentMap<InetAddressAndPort,OutboundConnections>	channelManagers
static java.lang.String	MBEAN_NAME
java.util.concurrent.ConcurrentMap<InetAddressAndPort,InboundMessageHandlers>	messageHandlers
MessagingMetrics	metrics
EndpointMessagingVersions	versions

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
java.util.Map<java.lang.String,java.lang.Double>	getBackPressurePerHost()	Back-pressure rate limiting per host
java.util.Map<java.lang.String,java.lang.Integer>	getDroppedMessages()	dropped message counts for server lifetime
java.util.Map<java.lang.String,java.lang.Long>	getGossipMessageCompletedTasks()	Completed tasks for gossip message TCP Connections
java.util.Map<java.lang.String,java.lang.Long>	getGossipMessageCompletedTasksWithPort()
java.util.Map<java.lang.String,java.lang.Long>	getGossipMessageDroppedTasks()	Dropped tasks for gossip message TCP Connections
java.util.Map<java.lang.String,java.lang.Long>	getGossipMessageDroppedTasksWithPort()
java.util.Map<java.lang.String,java.lang.Integer>	getGossipMessagePendingTasks()	Pending tasks for gossip message TCP Connections
java.util.Map<java.lang.String,java.lang.Integer>	getGossipMessagePendingTasksWithPort()
java.util.Map<java.lang.String,java.lang.Long>	getLargeMessageCompletedTasks()	Completed tasks for large message) TCP Connections
java.util.Map<java.lang.String,java.lang.Long>	getLargeMessageCompletedTasksWithPort()
java.util.Map<java.lang.String,java.lang.Long>	getLargeMessageDroppedTasks()	Dropped tasks for large message TCP Connections
java.util.Map<java.lang.String,java.lang.Long>	getLargeMessageDroppedTasksWithPort()
java.util.Map<java.lang.String,java.lang.Integer>	getLargeMessagePendingTasks()	Pending tasks for large message TCP Connections
java.util.Map<java.lang.String,java.lang.Integer>	getLargeMessagePendingTasksWithPort()
java.util.Map<java.lang.String,java.lang.Long>	getSmallMessageCompletedTasks()	Completed tasks for small message TCP Connections
java.util.Map<java.lang.String,java.lang.Long>	getSmallMessageCompletedTasksWithPort()
java.util.Map<java.lang.String,java.lang.Long>	getSmallMessageDroppedTasks()	Dropped tasks for small message TCP Connections
java.util.Map<java.lang.String,java.lang.Long>	getSmallMessageDroppedTasksWithPort()
java.util.Map<java.lang.String,java.lang.Integer>	getSmallMessagePendingTasks()	Pending tasks for small message TCP Connections
java.util.Map<java.lang.String,java.lang.Integer>	getSmallMessagePendingTasksWithPort()
java.util.Map<java.lang.String,java.lang.Long>	getTimeoutsPerHost()	Number of timeouts per host
java.util.Map<java.lang.String,java.lang.Long>	getTimeoutsPerHostWithPort()
long	getTotalTimeouts()	Total number of timeouts happened on this node
int	getVersion(java.lang.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 Detail

MBEAN_NAME

public static final java.lang.String MBEAN_NAME

See Also:

Constant Field Values

channelManagers

public final java.util.concurrent.ConcurrentMap<InetAddressAndPort,OutboundConnections> channelManagers

messageHandlers

public final java.util.concurrent.ConcurrentMap<InetAddressAndPort,InboundMessageHandlers> messageHandlers

versions

public final EndpointMessagingVersions versions

metrics

public final MessagingMetrics metrics

Constructor Detail

MessagingServiceMBeanImpl

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

Method Detail

getLargeMessagePendingTasks

public java.util.Map<java.lang.String,java.lang.Integer> getLargeMessagePendingTasks()

Description copied from interface: MessagingServiceMBean

Pending tasks for large message TCP Connections

Specified by:

getLargeMessagePendingTasks in interface MessagingServiceMBean

getLargeMessageCompletedTasks

public java.util.Map<java.lang.String,java.lang.Long> getLargeMessageCompletedTasks()

Description copied from interface: MessagingServiceMBean

Completed tasks for large message) TCP Connections

Specified by:

getLargeMessageCompletedTasks in interface MessagingServiceMBean

getLargeMessageDroppedTasks

public java.util.Map<java.lang.String,java.lang.Long> getLargeMessageDroppedTasks()

Description copied from interface: MessagingServiceMBean

Dropped tasks for large message TCP Connections

Specified by:

getLargeMessageDroppedTasks in interface MessagingServiceMBean

getSmallMessagePendingTasks

public java.util.Map<java.lang.String,java.lang.Integer> getSmallMessagePendingTasks()

Description copied from interface: MessagingServiceMBean

Pending tasks for small message TCP Connections

Specified by:

getSmallMessagePendingTasks in interface MessagingServiceMBean

getSmallMessageCompletedTasks

public java.util.Map<java.lang.String,java.lang.Long> getSmallMessageCompletedTasks()

Description copied from interface: MessagingServiceMBean

Completed tasks for small message TCP Connections

Specified by:

getSmallMessageCompletedTasks in interface MessagingServiceMBean

getSmallMessageDroppedTasks

public java.util.Map<java.lang.String,java.lang.Long> getSmallMessageDroppedTasks()

Description copied from interface: MessagingServiceMBean

Dropped tasks for small message TCP Connections

Specified by:

getSmallMessageDroppedTasks in interface MessagingServiceMBean

getGossipMessagePendingTasks

public java.util.Map<java.lang.String,java.lang.Integer> getGossipMessagePendingTasks()

Description copied from interface: MessagingServiceMBean

Pending tasks for gossip message TCP Connections

Specified by:

getGossipMessagePendingTasks in interface MessagingServiceMBean

getGossipMessageCompletedTasks

public java.util.Map<java.lang.String,java.lang.Long> getGossipMessageCompletedTasks()

Description copied from interface: MessagingServiceMBean

Completed tasks for gossip message TCP Connections

Specified by:

getGossipMessageCompletedTasks in interface MessagingServiceMBean

getGossipMessageDroppedTasks

public java.util.Map<java.lang.String,java.lang.Long> getGossipMessageDroppedTasks()

Description copied from interface: MessagingServiceMBean

Dropped tasks for gossip message TCP Connections

Specified by:

getGossipMessageDroppedTasks in interface MessagingServiceMBean

getLargeMessagePendingTasksWithPort

public java.util.Map<java.lang.String,java.lang.Integer> getLargeMessagePendingTasksWithPort()

Specified by:

getLargeMessagePendingTasksWithPort in interface MessagingServiceMBean

getLargeMessageCompletedTasksWithPort

public java.util.Map<java.lang.String,java.lang.Long> getLargeMessageCompletedTasksWithPort()

Specified by:

getLargeMessageCompletedTasksWithPort in interface MessagingServiceMBean

getLargeMessageDroppedTasksWithPort

public java.util.Map<java.lang.String,java.lang.Long> getLargeMessageDroppedTasksWithPort()

Specified by:

getLargeMessageDroppedTasksWithPort in interface MessagingServiceMBean

getSmallMessagePendingTasksWithPort

public java.util.Map<java.lang.String,java.lang.Integer> getSmallMessagePendingTasksWithPort()

Specified by:

getSmallMessagePendingTasksWithPort in interface MessagingServiceMBean

getSmallMessageCompletedTasksWithPort

public java.util.Map<java.lang.String,java.lang.Long> getSmallMessageCompletedTasksWithPort()

Specified by:

getSmallMessageCompletedTasksWithPort in interface MessagingServiceMBean

getSmallMessageDroppedTasksWithPort

public java.util.Map<java.lang.String,java.lang.Long> getSmallMessageDroppedTasksWithPort()

Specified by:

getSmallMessageDroppedTasksWithPort in interface MessagingServiceMBean

getGossipMessagePendingTasksWithPort

public java.util.Map<java.lang.String,java.lang.Integer> getGossipMessagePendingTasksWithPort()

Specified by:

getGossipMessagePendingTasksWithPort in interface MessagingServiceMBean

getGossipMessageCompletedTasksWithPort

public java.util.Map<java.lang.String,java.lang.Long> getGossipMessageCompletedTasksWithPort()

Specified by:

getGossipMessageCompletedTasksWithPort in interface MessagingServiceMBean

getGossipMessageDroppedTasksWithPort

public java.util.Map<java.lang.String,java.lang.Long> getGossipMessageDroppedTasksWithPort()

Specified by:

getGossipMessageDroppedTasksWithPort in interface MessagingServiceMBean

getDroppedMessages

public java.util.Map<java.lang.String,java.lang.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 java.util.Map<java.lang.String,java.lang.Long> getTimeoutsPerHost()

Description copied from interface: MessagingServiceMBean

Number of timeouts per host

Specified by:

getTimeoutsPerHost in interface MessagingServiceMBean

getTimeoutsPerHostWithPort

public java.util.Map<java.lang.String,java.lang.Long> getTimeoutsPerHostWithPort()

Specified by:

getTimeoutsPerHostWithPort in interface MessagingServiceMBean

getBackPressurePerHost

public java.util.Map<java.lang.String,java.lang.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(java.lang.String address)
               throws java.net.UnknownHostException

Specified by:

getVersion in interface MessagingServiceMBean

Throws:

java.net.UnknownHostException