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

Sending unread message as common messages instead of database messages

Browse Source
This commit is contained in:
Kai S. K. Engelbart 2020-02-03 07:06:52 +01:00
parent 79d11f4fba
commit f11ed4a585
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/envoy/server/processors/LoginCredentialProcessor.java
View File

@ -66,8 +66,8 @@ public class LoginCredentialProcessor implements ObjectProcessor<LoginCredential
System.out.println("Acquiring pending messages for the client..."); System.out.println("Acquiring pending messages for the client...");
List<Message> pendingMessages = PersistenceManager.getPersistenceManager().getUnreadMessages(user); List<Message> pendingMessages = PersistenceManager.getPersistenceManager().getUnreadMessages(user);
for (Message msg : pendingMessages) { for (Message msg : pendingMessages) {
System.out.println("Sending message " + msg.toString()); System.out.println("Sending message " + msg.toCommonMessage().toString());
writeProxy.write(socketId, msg); writeProxy.write(socketId, msg.toCommonMessage());
msg.setReceivedDate(new Date()); msg.setReceivedDate(new Date());
msg.setStatus(MessageStatus.RECEIVED); msg.setStatus(MessageStatus.RECEIVED);
PersistenceManager.getPersistenceManager().updateMessage(msg); PersistenceManager.getPersistenceManager().updateMessage(msg);