diff --git a/pom.xml b/pom.xml
index 244170b..046ec55 100755
--- a/pom.xml
+++ b/pom.xml
@@ -28,7 +28,7 @@
com.github.informatik-ag-ngl
envoy-common
- f~groups-SNAPSHOT
+ develop-SNAPSHOT
com.github.informatik-ag-ngl
diff --git a/src/main/java/envoy/server/data/Message.java b/src/main/java/envoy/server/data/Message.java
index 3a6604c..76c133c 100755
--- a/src/main/java/envoy/server/data/Message.java
+++ b/src/main/java/envoy/server/data/Message.java
@@ -76,14 +76,14 @@ public class Message {
*/
public Message(envoy.data.Message message) {
PersistenceManager persMan = PersistenceManager.getInstance();
- id = message.getId();
+ id = message.getID();
status = message.getStatus();
text = message.getText();
creationDate = message.getCreationDate();
receivedDate = message.getReceivedDate();
readDate = message.getReadDate();
- sender = persMan.getUserById(message.getSenderId());
- recipient = persMan.getUserById(message.getRecipientId());
+ sender = persMan.getUserById(message.getSenderID());
+ recipient = persMan.getUserById(message.getRecipientID());
forwarded = message.isForwarded();
// TODO: attachment = message.getAttachment().toByteArray();DOES NOT WORK YET
}
diff --git a/src/main/java/envoy/server/processors/ContactOperationProcessor.java b/src/main/java/envoy/server/processors/ContactOperationProcessor.java
index f906fb7..aaa9a29 100755
--- a/src/main/java/envoy/server/processors/ContactOperationProcessor.java
+++ b/src/main/java/envoy/server/processors/ContactOperationProcessor.java
@@ -26,7 +26,7 @@ public class ContactOperationProcessor implements ObjectProcessor {
message.nextStatus();
ConnectionManager connectionManager = ConnectionManager.getInstance();
- Contact recipient = PersistenceManager.getInstance().getContactById(message.getId());
+ Contact recipient = PersistenceManager.getInstance().getContactById(message.getID());
if (recipient instanceof envoy.server.data.User) {
System.out.println("The received message is a direct message.");
@@ -39,15 +39,15 @@ public class MessageProcessor implements ObjectProcessor {
try {
writeProxy.write(socketId, new MessageStatusChangeEvent(message));
} catch (IOException e) {
- System.err.println("Could not send messageStatusChangeEvent to the sender of this message with ID: " + message.getId());
+ System.err.println("Could not send messageStatusChangeEvent to the sender of this message with ID: " + message.getID());
e.printStackTrace();
}
} else {
System.out.println("The received message is a group message.");
- final var members = PersistenceManager.getInstance().getGroupById(message.getRecipientId()).getMembers();
+ final var members = PersistenceManager.getInstance().getGroupById(message.getRecipientID()).getMembers();
final var generator = IDGeneratorRequestProcessor.createIDGenerator(members.size());
members.forEach(user -> {
- envoy.data.Message returnMessage = new MessageBuilder(message.getRecipientId(), user.getID(), generator)
+ envoy.data.Message returnMessage = new MessageBuilder(message.getRecipientID(), user.getID(), generator)
.setDate(message.getCreationDate())
.setText(message.getText())
.setAttachment(message.getAttachment())
@@ -64,15 +64,15 @@ public class MessageProcessor implements ObjectProcessor {
}
private void sendToUser(ConnectionManager connectionManager, Message message, ObjectWriteProxy writeProxy) {
- if (connectionManager.isOnline(message.getRecipientId())) try {
+ if (connectionManager.isOnline(message.getRecipientID())) try {
// If recipient is online, send the message directly
- writeProxy.write(connectionManager.getSocketId(message.getRecipientId()), message);
+ writeProxy.write(connectionManager.getSocketId(message.getRecipientID()), message);
// Update the message status to RECEIVED
message.setReceivedDate(new Date());
message.nextStatus();
} catch (IOException e) {
- System.err.println("Recipient online. Failed to send message" + message.getId());
+ System.err.println("Recipient online. Failed to send message" + message.getID());
e.printStackTrace();
}
}
diff --git a/src/main/java/envoy/server/processors/MessageStatusChangeProcessor.java b/src/main/java/envoy/server/processors/MessageStatusChangeProcessor.java
index 3dce652..bd9c215 100755
--- a/src/main/java/envoy/server/processors/MessageStatusChangeProcessor.java
+++ b/src/main/java/envoy/server/processors/MessageStatusChangeProcessor.java
@@ -27,7 +27,7 @@ public class MessageStatusChangeProcessor implements ObjectProcessor