call onMessageFound outside sync block

1 files changed, 2 insertions, 14 deletions

diff --git a/src/main/java/de/pixart/messenger/services/XmppConnectionService.java b/src/main/java/de/pixart/messenger/services/XmppConnectionService.java
index b5574ca2a..068384a60 100644
--- a/src/main/java/de/pixart/messenger/services/XmppConnectionService.java
+++ b/src/main/java/de/pixart/messenger/services/XmppConnectionService.java
@@ -1482,13 +1482,7 @@ public class XmppConnectionService extends Service {
     }
 
     private void sendUnsentMessages(final Conversation conversation) {
-        conversation.findWaitingMessages(new Conversation.OnMessageFound() {
-
-            @Override
-            public void onMessageFound(Message message) {
-                resendMessage(message, true);
-            }
-        });
+        conversation.findWaitingMessages(message -> resendMessage(message, true));
     }
 
     private void resendFailedFileMessages(final Conversation conversation) {
@@ -3470,13 +3464,7 @@ public class XmppConnectionService extends Service {
         Log.d(Config.LOGTAG, account.getJid().asBareJid() + ": reset 'sending' messages to 'waiting'");
         for (Conversation conversation : getConversations()) {
             if (conversation.getAccount() == account) {
-                conversation.findUnsentTextMessages(new Conversation.OnMessageFound() {
-
-                    @Override
-                    public void onMessageFound(Message message) {
-                        markMessage(message, Message.STATUS_WAITING);
-                    }
-                });
+                conversation.findUnsentTextMessages(message -> markMessage(message, Message.STATUS_WAITING));
             }
         }
     }