@@ -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
	
	Block a user