Add prototype Messenger class to casemodule pacakge

This commit is contained in:
Richard Cordovano 2015-03-30 12:55:02 -04:00
parent 7367248fab
commit 9a256e4ba4
3 changed files with 7 additions and 5 deletions

View File

@ -146,6 +146,8 @@ public class Case implements SleuthkitCase.ErrorObserver {
// we cache if the case has data in it yet since a few places ask for it and we dont' need to keep going to DB
private boolean hasData = false;
private Messenger messenger;
/**
* Constructor for the Case class
*/
@ -158,6 +160,7 @@ public class Case implements SleuthkitCase.ErrorObserver {
this.db = db;
this.services = new Services(db);
db.addErrorObserver(this);
messenger = new Messenger(this.name);
}
/**
@ -299,6 +302,7 @@ public class Case implements SleuthkitCase.ErrorObserver {
}
Case newCase = new Case(caseName, caseNumber, examiner, configFilePath, xmlcm, db);
newCase.messenger.start();
changeCase(newCase);
}
@ -341,7 +345,8 @@ public class Case implements SleuthkitCase.ErrorObserver {
checkImagesExist(db);
Case openedCase = new Case(caseName, caseNumber, examiner, configFilePath, xmlcm, db);
openedCase.messenger.start();
changeCase(openedCase);
} catch (Exception ex) {
@ -492,6 +497,7 @@ public class Case implements SleuthkitCase.ErrorObserver {
changeCase(null);
try {
messenger.shutDown();
services.close();
this.xmlcm.close(); // close the xmlcm
this.db.close();

View File

@ -25,10 +25,8 @@ import javax.jms.Session;
import javax.jms.TextMessage;
import javax.jms.Topic;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.openide.modules.OnStart;
import org.sleuthkit.autopsy.coreutils.Logger;
@OnStart
public class Publisher implements Runnable {
private static final Logger logger = Logger.getLogger(Publisher.class.getName());

View File

@ -28,10 +28,8 @@ import javax.jms.Message;
import javax.jms.TextMessage;
import javax.jms.Topic;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.openide.modules.OnStart;
import org.sleuthkit.autopsy.coreutils.Logger;
@OnStart
public class Subscriber implements Runnable, ExceptionListener {
private static final Logger logger = Logger.getLogger(Subscriber.class.getName());