Updated javadocs

This commit is contained in:
Eugene Livis 2015-07-06 12:30:20 -04:00
parent bd39e37dde
commit 50708fc211
3 changed files with 58 additions and 15 deletions

View File

@ -99,43 +99,83 @@ public class ServicesMonitor {
periodicTasksExecutor.scheduleAtFixedRate(new CrashDetectionTask(), CRASH_DETECTION_INTERVAL_MINUTES, CRASH_DETECTION_INTERVAL_MINUTES, TimeUnit.MINUTES); periodicTasksExecutor.scheduleAtFixedRate(new CrashDetectionTask(), CRASH_DETECTION_INTERVAL_MINUTES, CRASH_DETECTION_INTERVAL_MINUTES, TimeUnit.MINUTES);
} }
// Subscribes to all events /**
* Adds an event subscriber to this publisher. Subscriber will be subscribed
* to all events from this publisher.
*
* @param subscriber The subscriber to add.
*/
public void addSubscriber(PropertyChangeListener subscriber) { public void addSubscriber(PropertyChangeListener subscriber) {
eventPublisher.addSubscriber(serviceNames, subscriber); eventPublisher.addSubscriber(serviceNames, subscriber);
} }
/**
* Adds an event subscriber to this publisher.
*
* @param eventNames The events the subscriber is interested in.
* @param subscriber The subscriber to add.
*/
public void addSubscriber(Set<String> eventNames, PropertyChangeListener subscriber) { public void addSubscriber(Set<String> eventNames, PropertyChangeListener subscriber) {
eventPublisher.addSubscriber(eventNames, subscriber);
} }
/**
* Adds an event subscriber to this publisher.
*
* @param eventName The event the subscriber is interested in.
* @param subscriber The subscriber to add.
*/
public void addSubscriber(String eventName, PropertyChangeListener subscriber) { public void addSubscriber(String eventName, PropertyChangeListener subscriber) {
eventPublisher.addSubscriber(eventName, subscriber);
} }
/**
* Removes an event subscriber from this publisher.
*
* @param eventNames The events the subscriber is no longer interested in.
* @param subscriber The subscriber to remove.
*/
public void removeSubscriber(Set<String> eventNames, PropertyChangeListener subscriber) { public void removeSubscriber(Set<String> eventNames, PropertyChangeListener subscriber) {
eventPublisher.removeSubscriber(eventNames, subscriber);
} }
/**
* Removes an event subscriber from this publisher.
*
* @param eventName The event the subscriber is no longer interested in.
* @param subscriber The subscriber to remove.
*/
public void removeSubscriber(String eventName, PropertyChangeListener subscriber) { public void removeSubscriber(String eventName, PropertyChangeListener subscriber) {
eventPublisher.removeSubscriber(eventName, subscriber);
} }
// Unsubscribes from all events /**
* Removes an event subscriber to this publisher. Subscriber will be removed
* from all event notifications from this publisher.
*
* @param subscriber The subscriber to remove.
*/
public void removeSubscriber(PropertyChangeListener subscriber) { public void removeSubscriber(PropertyChangeListener subscriber) {
eventPublisher.removeSubscriber(serviceNames, subscriber); eventPublisher.removeSubscriber(serviceNames, subscriber);
} }
/** /**
* Fire an event signifying change in remote database (e.g. PostgreSQL) service status. * Publish an event signifying change in remote database (e.g. PostgreSQL) service status.
*
* @param status Updated status for the event.
*/ */
void fireRemoteDatabaseStatusChange(ServiceStatus status) { void publishRemoteDatabaseStatusChange(ServiceStatus status) {
eventPublisher.publishLocally(new ServiceEvent(ServicesMonitor.Service.REMOTE_CASE_DATABASE.toString(), null, status.toString())); eventPublisher.publishLocally(new ServiceEvent(ServicesMonitor.Service.REMOTE_CASE_DATABASE.toString(), null, status.toString()));
} }
public void setServiceStatus(String service, String status, String details) { /**
* Publish a custom event.
*
* @param service Name of the service.
* @param status Updated status for the event.
* @param details Details of the event.
*/
public void publishServiceStatus(String service, String status, String details) {
eventPublisher.publishLocally(new ServiceEvent(service, status, details)); eventPublisher.publishLocally(new ServiceEvent(service, status, details));
} }
@ -164,14 +204,14 @@ public class ServicesMonitor {
dbServerIsRunning = true; dbServerIsRunning = true;
logger.log(Level.INFO, "Connection to PostgreSQL server restored"); //NON-NLS logger.log(Level.INFO, "Connection to PostgreSQL server restored"); //NON-NLS
//MessageNotifyUtil.Notify.info(NbBundle.getMessage(CollaborationMonitor.class, "CollaborationMonitor.restoredService.notify.title"), NbBundle.getMessage(CollaborationMonitor.class, "CollaborationMonitor.restoredDbService.notify.msg")); //MessageNotifyUtil.Notify.info(NbBundle.getMessage(CollaborationMonitor.class, "CollaborationMonitor.restoredService.notify.title"), NbBundle.getMessage(CollaborationMonitor.class, "CollaborationMonitor.restoredDbService.notify.msg"));
fireRemoteDatabaseStatusChange(ServiceStatus.UP); publishRemoteDatabaseStatusChange(ServiceStatus.UP);
} }
} else { } else {
if (dbServerIsRunning) { if (dbServerIsRunning) {
dbServerIsRunning = false; dbServerIsRunning = false;
logger.log(Level.SEVERE, "Failed to connect to PostgreSQL server"); //NON-NLS logger.log(Level.SEVERE, "Failed to connect to PostgreSQL server"); //NON-NLS
//MessageNotifyUtil.Notify.error(NbBundle.getMessage(CollaborationMonitor.class, "CollaborationMonitor.failedService.notify.title"), NbBundle.getMessage(CollaborationMonitor.class, "CollaborationMonitor.failedDbService.notify.msg")); //MessageNotifyUtil.Notify.error(NbBundle.getMessage(CollaborationMonitor.class, "CollaborationMonitor.failedService.notify.title"), NbBundle.getMessage(CollaborationMonitor.class, "CollaborationMonitor.failedDbService.notify.msg"));
fireRemoteDatabaseStatusChange(ServiceStatus.DOWN); publishRemoteDatabaseStatusChange(ServiceStatus.DOWN);
} }
} }

View File

@ -120,7 +120,7 @@ public final class AutopsyEventPublisher {
/** /**
* Removes an event subscriber from this publisher. * Removes an event subscriber from this publisher.
* *
* @param eventNames The event the subscriber is no longer interested in. * @param eventName The event the subscriber is no longer interested in.
* @param subscriber The subscriber to remove. * @param subscriber The subscriber to remove.
*/ */
public void removeSubscriber(String eventName, PropertyChangeListener subscriber) { public void removeSubscriber(String eventName, PropertyChangeListener subscriber) {

View File

@ -335,6 +335,9 @@ public class IngestManager {
String eventType = evt.getPropertyName(); String eventType = evt.getPropertyName();
if (eventType.equals(ServicesMonitor.Service.REMOTE_CASE_DATABASE.toString())) { if (eventType.equals(ServicesMonitor.Service.REMOTE_CASE_DATABASE.toString())) {
if (evt.getNewValue() == ServicesMonitor.ServiceStatus.DOWN) { if (evt.getNewValue() == ServicesMonitor.ServiceStatus.DOWN) {
// TODO - display notification
// cancel ingest if running // cancel ingest if running
cancelAllIngestJobs(); cancelAllIngestJobs();
} }