net.rim.pushsdk.monitoring
Class MonitoringServiceImpl

java.lang.Object
  extended by net.rim.pushsdk.monitoring.MonitoringServiceImpl
All Implemented Interfaces:
MonitoringService

@ManagedResource(objectName="bean:name=BPSSMonitor",
                 description="Monitor acknowledgements and push stats",
                 log=false,
                 persistPolicy="Never")
public class MonitoringServiceImpl
extends Object
implements MonitoringService

Implementation of the MonitoringService interface.

Author:
mdandrea

Constructor Summary
MonitoringServiceImpl()
           
 
Method Summary
 int getNotificationListenerActiveThreadCount()
          Returns the number of threads actively calling notification listeners.
 int getNotificationListenerThreadPoolSize()
          Returns the number of threads currently in the thread pool (active and idle) for the notification listener service.
 int getNotificationListenerWorkQueueSize()
          Returns the size of the work queue of the notification listener service which holds tasks (Runnables) waiting to be picked up and processed using an active thread.
 int getNotificationProcessorActiveThreadCount()
          Returns the number of threads actively processing notifications.
 int getNotificationProcessorQueueSize()
          Returns the size of the result notification queue.
 int getNotificationProcessorThreadPoolSize()
          Returns the number of threads currently in the thread pool (active and idle) for the notification processor service.
 int getNotificationProcessorWorkQueueSize()
          Returns the size of the work queue of the notification processor service which holds tasks (Runnables) waiting to be picked up and processed using an active thread.
 int getPushStatsQueueSize()
          Returns the size of the queue holding push stats waiting to be batched and processed.
 void setNotificationListenerService(NotificationListenerService notificationListenerService)
          Support for dependency injection.
 void setNotificationProcessorService(NotificationProcessorService notificationProcessorService)
          Support for dependency injection.
 void setPushStatsBatchUpdaterService(PushStatsBatchUpdaterService pushStatsBatchUpdaterService)
          Support for dependency injection.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MonitoringServiceImpl

public MonitoringServiceImpl()
Method Detail

setNotificationProcessorService

public void setNotificationProcessorService(NotificationProcessorService notificationProcessorService)
Description copied from interface: MonitoringService
Support for dependency injection. Inject an implementation of a NotificationProcessorService collaborating object.

Specified by:
setNotificationProcessorService in interface MonitoringService
Parameters:
notificationProcessorService - an instance of a NotificationProcessorService implementation (must be thread safe)

setNotificationListenerService

public void setNotificationListenerService(NotificationListenerService notificationListenerService)
Description copied from interface: MonitoringService
Support for dependency injection. Inject an implementation of a NotificationListenerService collaborating object.

Specified by:
setNotificationListenerService in interface MonitoringService
Parameters:
notificationListenerService - an instance of a NotificationListenerService implementation (must be thread safe)

setPushStatsBatchUpdaterService

public void setPushStatsBatchUpdaterService(PushStatsBatchUpdaterService pushStatsBatchUpdaterService)
Description copied from interface: MonitoringService
Support for dependency injection. Sets the PushStatsBatchUpdaterService to use.

Specified by:
setPushStatsBatchUpdaterService in interface MonitoringService
Parameters:
pushStatsBatchUpdaterService - the Push Stats Batch Updater Service

getNotificationListenerActiveThreadCount

@ManagedAttribute(description="Active Thread Count for the Notification Listener Service")
public int getNotificationListenerActiveThreadCount()
Description copied from interface: MonitoringService
Returns the number of threads actively calling notification listeners.

Specified by:
getNotificationListenerActiveThreadCount in interface MonitoringService
Returns:
the number of active processing threads

getNotificationListenerThreadPoolSize

@ManagedAttribute(description="Thread Pool Size for the Notification Listener Service")
public int getNotificationListenerThreadPoolSize()
Description copied from interface: MonitoringService
Returns the number of threads currently in the thread pool (active and idle) for the notification listener service.

Specified by:
getNotificationListenerThreadPoolSize in interface MonitoringService
Returns:
the number of threads in the thread pool

getNotificationListenerWorkQueueSize

@ManagedAttribute(description="Work Queue Size for the Notification Listener Service")
public int getNotificationListenerWorkQueueSize()
Description copied from interface: MonitoringService
Returns the size of the work queue of the notification listener service which holds tasks (Runnables) waiting to be picked up and processed using an active thread.

Specified by:
getNotificationListenerWorkQueueSize in interface MonitoringService
Returns:
the size of the work queue

getNotificationProcessorActiveThreadCount

@ManagedAttribute(description="Active Thread Count for the Notification Processor Service")
public int getNotificationProcessorActiveThreadCount()
Description copied from interface: MonitoringService
Returns the number of threads actively processing notifications.

Specified by:
getNotificationProcessorActiveThreadCount in interface MonitoringService
Returns:
the number of active processing threads

getNotificationProcessorQueueSize

@ManagedAttribute(description="Notifications Queue Size for the Notification Processor Service")
public int getNotificationProcessorQueueSize()
Description copied from interface: MonitoringService
Returns the size of the result notification queue.

Specified by:
getNotificationProcessorQueueSize in interface MonitoringService
Returns:
the size of the result notification queue

getNotificationProcessorThreadPoolSize

@ManagedAttribute(description="Thread Pool Size for the Notification Processor Service")
public int getNotificationProcessorThreadPoolSize()
Description copied from interface: MonitoringService
Returns the number of threads currently in the thread pool (active and idle) for the notification processor service.

Specified by:
getNotificationProcessorThreadPoolSize in interface MonitoringService
Returns:
the number of threads in the thread pool

getNotificationProcessorWorkQueueSize

@ManagedAttribute(description="Work Queue Size for the Notification Processor Service")
public int getNotificationProcessorWorkQueueSize()
Description copied from interface: MonitoringService
Returns the size of the work queue of the notification processor service which holds tasks (Runnables) waiting to be picked up and processed using an active thread.

Specified by:
getNotificationProcessorWorkQueueSize in interface MonitoringService
Returns:
the size of the work queue

getPushStatsQueueSize

@ManagedAttribute(description="Queue Size for push stats ready to be batched and persisted")
public int getPushStatsQueueSize()
Description copied from interface: MonitoringService
Returns the size of the queue holding push stats waiting to be batched and processed.

Specified by:
getPushStatsQueueSize in interface MonitoringService
Returns:
the size of the push stats queue


Copyright © 2011 Research In Motion. All Rights Reserved.