mstoeck3/autopsy-flatpak
1
0
Fork 0
mirror of https://github.com/overcuriousity/autopsy-flatpak.git synced 2025-07-06 21:00:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #1512 from eugene7646/remote_publisher

Browse Source 
Remote publisher changes
This commit is contained in:
esaunders 2015-08-17 11:26:51 -04:00
commit d928d961e1
1 changed files with 34 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

64
Core/src/org/sleuthkit/autopsy/events/RemoteEventPublisher.java
View File

@ -144,40 +144,44 @@ final class RemoteEventPublisher {
*/
@Override
public void onMessage(Message message) {
if (IngestManager.getInstance().isRunningInteractively()) {
/**
* This is a stop gap measure until a different way of handling
* the closing of cases is worked out. Currently,
* Case.currentCase is set to null before
* Case.Event.CURRENT_CASE is published. That means that clients
* of this class have not had the chance to close their remote
* event channels and remote events may be received for a case
* that is already closed.
*/
try {
Case.getCurrentCase();
} catch (IllegalStateException notUsed) {
/**
* Case is closed, do not publish the event.
*/
return;
}
try {
if (message instanceof ObjectMessage) {
ObjectMessage objectMessage = (ObjectMessage) message;
Object object = objectMessage.getObject();
if (object instanceof AutopsyEvent) {
AutopsyEvent event = (AutopsyEvent) object;
event.setSourceType(AutopsyEvent.SourceType.REMOTE);
localPublisher.publish(event);
}
/**
* TODO! Applications not running interactively also need to receive
* remote events. We need to figure out how to handle case closing
* issue differently.
*
* if (IngestManager.getInstance().isRunningInteractively()) {
*
* This is a stop gap measure until a different way of handling the
* closing of cases is worked out. Currently, Case.currentCase is
* set to null before Case.Event.CURRENT_CASE is published. That
* means that clients of this class have not had the chance to close
* their remote event channels and remote events may be received for
* a case that is already closed.
*/
/** TODO! Remote events may not be related to current case. It can
* be a status/priority/UI update.
try {
Case.getCurrentCase();
} catch (IllegalStateException notUsed) {
// Case is closed, do not publish the event.
return;
} **/
try {
if (message instanceof ObjectMessage) {
ObjectMessage objectMessage = (ObjectMessage) message;
Object object = objectMessage.getObject();
if (object instanceof AutopsyEvent) {
AutopsyEvent event = (AutopsyEvent) object;
event.setSourceType(AutopsyEvent.SourceType.REMOTE);
localPublisher.publish(event);
}
} catch (Exception ex) {
logger.log(Level.SEVERE, "Error receiving message", ex);
}
} catch (Exception ex) {
logger.log(Level.SEVERE, "Error receiving message", ex);
}
}
}
}