org.jumpmind.symmetric.service.impl

Class MonitorService

java.lang.Object

org.jumpmind.symmetric.service.impl.AbstractService

org.jumpmind.symmetric.service.impl.MonitorService

All Implemented Interfaces:

IMonitorService, IService

public class MonitorService
extends AbstractService
implements IMonitorService

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.List<Monitor>	activeMonitorCache
protected long	activeMonitorCacheTime
protected java.util.List<Notification>	activeNotificationCache
protected long	activeNotificationCacheTime
protected java.util.Map<java.lang.String,java.util.List<java.lang.Long>>	averagesByType
protected java.util.Map<java.lang.String,java.lang.Long>	checkTimesByType
protected IClusterService	clusterService
protected IContextService	contextService
protected IExtensionService	extensionService
protected java.lang.String	hostName
protected INodeService	nodeService
protected java.lang.String	typeColumnName

Fields inherited from class org.jumpmind.symmetric.service.impl.AbstractService

log, parameterService, platform, sqlTemplate, sqlTemplateDirty, symmetricDialect, tablePrefix

Constructor Summary

Constructors

Constructor and Description
MonitorService(IParameterService parameterService, ISymmetricDialect symmetricDialect, INodeService nodeService, IExtensionService extensionService, IClusterService clusterService, IContextService contextService)

Method Summary

Modifier and Type	Method and Description
void	deleteMonitor(java.lang.String monitorId)
void	deleteMonitorEvent(MonitorEvent event)
void	deleteNotification(java.lang.String notificationId)
void	flushMonitorCache()
void	flushNotificationCache()
java.util.List<Monitor>	getActiveMonitorsForNode(java.lang.String nodeGroupId, java.lang.String externalId)
java.util.List<Monitor>	getActiveMonitorsUnresolvedForNode(java.lang.String nodeGroupId, java.lang.String externalId)
java.util.List<Notification>	getActiveNotificationsForNode(java.lang.String nodeGroupId, java.lang.String externalId)
java.util.List<MonitorEvent>	getMonitorEvents()
java.util.List<MonitorEvent>	getMonitorEventsFiltered(int limit, java.lang.String type, int severityLevel, java.lang.String nodeId, java.lang.Boolean isResolved)
protected java.util.List<MonitorEvent>	getMonitorEventsForNotification(int severityLevel)
protected java.util.Map<java.lang.String,MonitorEvent>	getMonitorEventsNotResolvedForNode(java.lang.String nodeId)
java.util.List<Monitor>	getMonitors()
java.util.List<Notification>	getNotifications()
protected void	insertMonitorEvent(MonitorEvent event)
void	saveMonitor(Monitor monitor)
void	saveMonitorEvent(MonitorEvent event)
void	saveNotification(Notification notification)
void	update()
protected void	updateMonitor(Monitor monitor, IMonitorType monitorType, Node identity, java.util.Map<java.lang.String,MonitorEvent> unresolved)
protected boolean	updateMonitorEvent(MonitorEvent event)
protected void	updateMonitorEventAsNotified(java.util.List<MonitorEvent> events)
protected void	updateMonitorEventAsNotified(MonitorEvent event)
void	updateMonitorEventAsResolved(MonitorEvent event)

Methods inherited from class org.jumpmind.symmetric.service.impl.AbstractService

assertNotNull, buildBatchWhere, close, createSqlReplacementTokens, createSqlReplacementTokens, getJdbcTemplate, getParameterService, getSql, getSymmetricDialect, getTablePrefix, getTargetDialect, getTargetPlatform, getTargetPlatform, isCalledFromSymmetricAdminTool, isSet, isStreamClosedByClient, isSymmetricTable, logOnce, maxDate, readAcks, sendAck, setSqlMap, synchronize, toNodeIds, toNodeIds

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

hostName

protected java.lang.String hostName

nodeService

protected INodeService nodeService

extensionService

protected IExtensionService extensionService

clusterService

protected IClusterService clusterService

contextService

protected IContextService contextService

checkTimesByType

protected java.util.Map<java.lang.String,java.lang.Long> checkTimesByType

averagesByType

protected java.util.Map<java.lang.String,java.util.List<java.lang.Long>> averagesByType

activeMonitorCache

protected java.util.List<Monitor> activeMonitorCache

activeMonitorCacheTime

protected long activeMonitorCacheTime

activeNotificationCache

protected java.util.List<Notification> activeNotificationCache

activeNotificationCacheTime

protected long activeNotificationCacheTime

typeColumnName

protected java.lang.String typeColumnName

Constructor Detail

MonitorService

public MonitorService(IParameterService parameterService,
                      ISymmetricDialect symmetricDialect,
                      INodeService nodeService,
                      IExtensionService extensionService,
                      IClusterService clusterService,
                      IContextService contextService)

Method Detail

update

public void update()

Specified by:

update in interface IMonitorService

updateMonitor

protected void updateMonitor(Monitor monitor,
                             IMonitorType monitorType,
                             Node identity,
                             java.util.Map<java.lang.String,MonitorEvent> unresolved)

getMonitors

public java.util.List<Monitor> getMonitors()

Specified by:

getMonitors in interface IMonitorService

getActiveMonitorsForNode

public java.util.List<Monitor> getActiveMonitorsForNode(java.lang.String nodeGroupId,
                                                        java.lang.String externalId)

Specified by:

getActiveMonitorsForNode in interface IMonitorService

getActiveMonitorsUnresolvedForNode

public java.util.List<Monitor> getActiveMonitorsUnresolvedForNode(java.lang.String nodeGroupId,
                                                                  java.lang.String externalId)

Specified by:

getActiveMonitorsUnresolvedForNode in interface IMonitorService

deleteMonitor

public void deleteMonitor(java.lang.String monitorId)

Specified by:

deleteMonitor in interface IMonitorService

saveMonitor

public void saveMonitor(Monitor monitor)

Specified by:

saveMonitor in interface IMonitorService

getMonitorEvents

public java.util.List<MonitorEvent> getMonitorEvents()

Specified by:

getMonitorEvents in interface IMonitorService

getMonitorEventsNotResolvedForNode

protected java.util.Map<java.lang.String,MonitorEvent> getMonitorEventsNotResolvedForNode(java.lang.String nodeId)

getMonitorEventsFiltered

public java.util.List<MonitorEvent> getMonitorEventsFiltered(int limit,
                                                             java.lang.String type,
                                                             int severityLevel,
                                                             java.lang.String nodeId,
                                                             java.lang.Boolean isResolved)

Specified by:

getMonitorEventsFiltered in interface IMonitorService

getMonitorEventsForNotification

protected java.util.List<MonitorEvent> getMonitorEventsForNotification(int severityLevel)

saveMonitorEvent

public void saveMonitorEvent(MonitorEvent event)

Specified by:

saveMonitorEvent in interface IMonitorService

insertMonitorEvent

protected void insertMonitorEvent(MonitorEvent event)

updateMonitorEvent

protected boolean updateMonitorEvent(MonitorEvent event)

deleteMonitorEvent

public void deleteMonitorEvent(MonitorEvent event)

Specified by:

deleteMonitorEvent in interface IMonitorService

updateMonitorEventAsNotified

protected void updateMonitorEventAsNotified(java.util.List<MonitorEvent> events)

updateMonitorEventAsNotified

protected void updateMonitorEventAsNotified(MonitorEvent event)

updateMonitorEventAsResolved

public void updateMonitorEventAsResolved(MonitorEvent event)

Specified by:

updateMonitorEventAsResolved in interface IMonitorService

getNotifications

public java.util.List<Notification> getNotifications()

Specified by:

getNotifications in interface IMonitorService

getActiveNotificationsForNode

public java.util.List<Notification> getActiveNotificationsForNode(java.lang.String nodeGroupId,
                                                                  java.lang.String externalId)

Specified by:

getActiveNotificationsForNode in interface IMonitorService

saveNotification

public void saveNotification(Notification notification)

Specified by:

saveNotification in interface IMonitorService

deleteNotification

public void deleteNotification(java.lang.String notificationId)

Specified by:

deleteNotification in interface IMonitorService

flushMonitorCache

public void flushMonitorCache()

Specified by:

flushMonitorCache in interface IMonitorService

flushNotificationCache

public void flushNotificationCache()

Specified by:

flushNotificationCache in interface IMonitorService