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