net.rim.pushsdk.monitoring
Class MonitoringServiceImpl

java.lang.Object
  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