com.waveset.adapter
Class ResourceActivityReporter
java.lang.Object
javax.management.NotificationBroadcasterSupport
com.sun.idm.management.AbstractDynamicMBean
com.sun.idm.management.BaseDynamicMBean
com.waveset.adapter.ResourceActivityReporter
- All Implemented Interfaces:
- javax.management.DynamicMBean, javax.management.NotificationBroadcaster, javax.management.NotificationEmitter
- public class ResourceActivityReporter
- extends com.sun.idm.management.BaseDynamicMBean
This class is responsible for updating activity status for resources in the
repository. It uses a queue and a thread to allow asnychonrous writes. We
don't want to add bottle neck to the resource adapter proxy.
Field Summary |
static java.lang.String |
CLASS
|
Methods inherited from class com.sun.idm.management.BaseDynamicMBean |
createMBeanAttributeInfo, createMBeanConstructorInfo, createMBeanNotificationInfo, createMBeanOperationInfo, getMBeanClassName, getMBeanDescription |
Methods inherited from class com.sun.idm.management.AbstractDynamicMBean |
createMBeanInfo, getAttribute, getAttributes, getMBeanInfo, invoke, setAttribute, setAttributes |
Methods inherited from class javax.management.NotificationBroadcasterSupport |
addNotificationListener, getNotificationInfo, handleNotification, removeNotificationListener, removeNotificationListener, sendNotification |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
CLASS
public static final java.lang.String CLASS
- See Also:
- Constant Field Values
start
public void start()
- Start queue processing.
stop
public void stop()
- Stop queue processing.
restart
public void restart()
- Restart the thread and reset the queue.
getCount
public long getCount()
- Returns:
- Process count.
getSize
public long getSize()
- Returns:
- The current size of the queue.
report
public static void report(LighthouseContext lh,
Resource res,
java.lang.String op,
WSUser ws)
report
public static void report(LighthouseContext lh,
Resource res,
java.lang.String op,
GenericObject go)