com.waveset.adapter
Class ResourceActivityReporter

java.lang.Object
  extended byjavax.management.NotificationBroadcasterSupport
      extended bycom.sun.idm.management.AbstractDynamicMBean
          extended bycom.sun.idm.management.BaseDynamicMBean
              extended bycom.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
           
 
Method Summary
 long getCount()
           
 long getSize()
           
static void report(LighthouseContext lh, Resource res, java.lang.String op, GenericObject go)
           
static void report(LighthouseContext lh, Resource res, java.lang.String op, WSUser ws)
           
 void restart()
          Restart the thread and reset the queue.
 void start()
          Start queue processing.
 void stop()
          Stop queue processing.
 
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
 

Field Detail

CLASS

public static final java.lang.String CLASS
See Also:
Constant Field Values
Method Detail

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)