public class

MessageQueueMonitor

extends Object
implements MessageQueueMonitorMBean
java.lang.Object
   ↳ org.apache.helix.monitoring.mbeans.MessageQueueMonitor

Summary

Public Constructors
MessageQueueMonitor(String clusterName, String instanceName)
Public Methods
long getMessageQueueBacklog()
Get the message queue size
ObjectName getObjectName(String name)
String getSensorName()
void init()
Register this bean with the server
void reset()
Remove this bean from the server
void setMessageQueueBacklog(long size)
Set the current backlog size for this instance
[Expand]
Inherited Methods
From class java.lang.Object
From interface org.apache.helix.monitoring.SensorNameProvider
From interface org.apache.helix.monitoring.mbeans.MessageQueueMonitorMBean

Public Constructors

public MessageQueueMonitor (String clusterName, String instanceName)

Public Methods

public long getMessageQueueBacklog ()

Get the message queue size

public ObjectName getObjectName (String name)

public String getSensorName ()

public void init ()

Register this bean with the server

public void reset ()

Remove this bean from the server

public void setMessageQueueBacklog (long size)

Set the current backlog size for this instance

Parameters
size the message queue size