zdm/envoy
zdm/envoy
Archived
3
Fork 0
Code Issues 22 Pull Requests Releases 1 Wiki Activity

Reimplemented RECEIVED update sending to sender

Browse Source
This commit is contained in:
DieGurke 2020-07-05 13:28:48 +02:00
parent 8ba70407af
commit 83ddc02187
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/main/java/envoy/server/processors/GroupMessageProcessor.java
View File

@ -8,6 +8,7 @@ import javax.persistence.EntityExistsException;
import envoy.data.GroupMessage; import envoy.data.GroupMessage;
import envoy.data.Message.MessageStatus; import envoy.data.Message.MessageStatus;
import envoy.event.MessageStatusChange;
import envoy.server.data.PersistenceManager; import envoy.server.data.PersistenceManager;
import envoy.server.net.ConnectionManager; import envoy.server.net.ConnectionManager;
import envoy.server.net.ObjectWriteProxy; import envoy.server.net.ObjectWriteProxy;
@ -42,12 +43,12 @@ public class GroupMessageProcessor implements ObjectProcessor<GroupMessage> {
// sender, if he is still online. // sender, if he is still online.
if (!groupMessage.getMemberStatuses().containsValue(MessageStatus.SENT)) { if (!groupMessage.getMemberStatuses().containsValue(MessageStatus.SENT)) {
groupMessage.setStatus(MessageStatus.RECEIVED); groupMessage.setStatus(MessageStatus.RECEIVED);
// if (connectionManager.isOnline(connectionManager.getUserIdBySocketID(socketID))) try { if (connectionManager.isOnline(connectionManager.getUserIdBySocketID(socketID))) try {
// writeProxy.write(socketID, new MessageStatusChange(groupMessage)); writeProxy.write(socketID, new MessageStatusChange(groupMessage));
// } catch (IOException e) { } catch (IOException e) {
// logger.warning("Sender of the groupMessage online. Failed to send MessageStatusChange"); logger.warning("Sender of the groupMessage online. Failed to send MessageStatusChange");
// e.printStackTrace(); e.printStackTrace();
// } }
} }
members.stream() members.stream()