public class QueueMBean extends AbstractMBean<IQueue<?>>
Modifier and Type | Field and Description |
---|---|
protected ItemListener |
listener |
logger, managementService, mbeanServer
Constructor and Description |
---|
QueueMBean(IQueue<?> queue,
ManagementService managementService) |
Modifier and Type | Method and Description |
---|---|
void |
clear()
Clear queue
|
String |
getConfig() |
long |
getItemsReceived() |
double |
getItemsReceivedAvg() |
double |
getItemsReceivedMax() |
long |
getItemsServed() |
double |
getItemsServedAvg() |
double |
getItemsServedMax() |
String |
getName() |
ObjectNameSpec |
getNameSpec()
Override to provide a JMX name
|
void |
postRegister(Boolean registrationDone)
From interface
MBeanRegistration |
void |
preDeregister()
From interface
MBeanRegistration |
void |
resetStats()
Resets statistics
|
int |
size() |
getAttribute, getAttributes, getManagedObject, getMBeanInfo, getObjectName, getParentName, invoke, postDeregister, preRegister, refresh, setAttribute, setAttributes, setParentName
protected ItemListener listener
public QueueMBean(IQueue<?> queue, ManagementService managementService)
public ObjectNameSpec getNameSpec()
AbstractMBean
getNameSpec
in class AbstractMBean<IQueue<?>>
public void postRegister(Boolean registrationDone)
AbstractMBean
MBeanRegistration
postRegister
in interface MBeanRegistration
postRegister
in class AbstractMBean<IQueue<?>>
public void preDeregister() throws Exception
AbstractMBean
MBeanRegistration
preDeregister
in interface MBeanRegistration
preDeregister
in class AbstractMBean<IQueue<?>>
Exception
public void resetStats()
public void clear()
public String getName()
public String getConfig()
public int size()
public long getItemsReceived()
public double getItemsReceivedAvg()
public double getItemsReceivedMax()
public long getItemsServed()
public double getItemsServedAvg()
public double getItemsServedMax()
Copyright © 2008-2013 Hazelcast, Inc. All Rights Reserved.