parent
900304c250
commit
5d71ae5910
|
@ -131,7 +131,7 @@ public class Client implements Closeable {
|
||||||
receiver.registerProcessor(MessageStatusChange.class, messageStatusChangeProcessor);
|
receiver.registerProcessor(MessageStatusChange.class, messageStatusChangeProcessor);
|
||||||
receiver.registerProcessor(GroupMessageStatusChange.class, groupMessageStatusChangeProcessor);
|
receiver.registerProcessor(GroupMessageStatusChange.class, groupMessageStatusChangeProcessor);
|
||||||
|
|
||||||
// Relay caches
|
// Relay cached messages and message status changes
|
||||||
cacheMap.get(Message.class).setProcessor(receivedMessageProcessor);
|
cacheMap.get(Message.class).setProcessor(receivedMessageProcessor);
|
||||||
cacheMap.get(GroupMessage.class).setProcessor(receivedGroupMessageProcessor);
|
cacheMap.get(GroupMessage.class).setProcessor(receivedGroupMessageProcessor);
|
||||||
cacheMap.get(MessageStatusChange.class).setProcessor(messageStatusChangeProcessor);
|
cacheMap.get(MessageStatusChange.class).setProcessor(messageStatusChangeProcessor);
|
||||||
|
|
Reference in New Issue