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

Simplify MessageServiceConnectionInfo API, tidy Messenger

Browse Source
This commit is contained in:
Richard Cordovano 2015-04-14 12:46:39 -04:00
parent 14f49ff78c
commit 10a8e731f7
4 changed files with 9 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
Core/src/org/sleuthkit/autopsy/core/UserPreferences.java
View File

@ -142,8 +142,8 @@ public final class UserPreferences {
public static void setMessageServiceConnectionInfo(MessageServiceConnectionInfo info) {
preferences.put(MESSAGE_SERVICE_USER, info.getUserName());
preferences.put(MESSAGE_SERVICE_PASSWORD, info.getPassword());
preferences.put(MESSAGE_SERVICE_HOST, info.getHost());
preferences.put(MESSAGE_SERVICE_PORT, Integer.toString(info.getPort()));
preferences.put(MESSAGE_SERVICE_HOST, info.getURI().getHost());
preferences.put(MESSAGE_SERVICE_PORT, Integer.toString(info.getURI().getPort()));
}
/**

23
Core/src/org/sleuthkit/autopsy/core/messenger/MessageServiceConnectionInfo.java
View File

@ -36,7 +36,7 @@ public final class MessageServiceConnectionInfo {
* Service (JMS) provider.
*
* @param userName The user name to use for a message service connection.
* @param password the password to use for a message service connection.
* @param password The password to use for a message service connection.
* @param host The host to use for a message service connection. May be a
* host name or an IP address.
* @param port The port number to use for a message service connection.
@ -65,32 +65,13 @@ public final class MessageServiceConnectionInfo {
public String getPassword() {
return password;
}
/**
* Gets the host to use for a message service connection. May be a host name
* or an IP address.
*
* @return The host as a string.
*/
public String getHost() {
return uri.getHost();
}
/**
* Gets the port number to use for a message service connection.
*
* @return The port as a string.
*/
public int getPort() {
return uri.getPort();
}
/**
* Gets the TCP URI to use for a message service connection.
*
* @return The URI.
*/
URI getURI() {
public URI getURI() {
return uri;
}

6
Core/src/org/sleuthkit/autopsy/core/messenger/Messenger.java
View File

@ -29,11 +29,11 @@ import javax.jms.ObjectMessage;
import javax.jms.Session;
import javax.jms.Topic;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.sleuthkit.autopsy.casemodule.Case;
import org.sleuthkit.autopsy.coreutils.Logger;
public final class Messenger implements MessageListener {
private static final String ALL_MESSAGE_SELECTOR = "All";
private static final Logger logger = Logger.getLogger(Messenger.class.getName());
private final String caseName;
private Connection connection;
@ -52,7 +52,7 @@ public final class Messenger implements MessageListener {
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Topic topic = session.createTopic(caseName);
producer = session.createProducer(topic);
MessageConsumer consumer = session.createConsumer(topic, "event = '" + Case.Events.DATA_SOURCE_ADDED.toString() + "'", true);
MessageConsumer consumer = session.createConsumer(topic, "events = '" + ALL_MESSAGE_SELECTOR + "'", true);
consumer.setMessageListener(this);
} catch (Exception ex) {
logger.log(Level.SEVERE, "Startup error", ex);
@ -71,7 +71,7 @@ public final class Messenger implements MessageListener {
public void send(PropertyChangeEvent event) {
try {
ObjectMessage message = session.createObjectMessage();
message.setStringProperty("event", Case.Events.DATA_SOURCE_ADDED.toString());
message.setStringProperty("events", ALL_MESSAGE_SELECTOR);
message.setObject(event);
producer.send(message);
} catch (Exception ex) {

4
Core/src/org/sleuthkit/autopsy/corecomponents/MultiUserSettingsPanel.java
View File

@ -350,8 +350,8 @@ public final class MultiUserSettingsPanel extends javax.swing.JPanel {
MessageServiceConnectionInfo msgServiceInfo = null;
try {
msgServiceInfo = UserPreferences.getMessageServiceConnectionInfo();
msgHostTextField.setText(msgServiceInfo.getHost());
msgPortTextField.setText(Integer.toString(msgServiceInfo.getPort()));
msgHostTextField.setText(msgServiceInfo.getURI().getHost());
msgPortTextField.setText(Integer.toString(msgServiceInfo.getURI().getPort()));
msgUserNameTextField.setText(msgServiceInfo.getUserName());
msgPasswordField.setText(msgServiceInfo.getPassword());
msgRetypePasswordField.setText(msgServiceInfo.getPassword());