diff --git a/src/main/java/ru/bvn13/jircbot/database/services/DeferredMessageService.java b/src/main/java/ru/bvn13/jircbot/database/services/DeferredMessageService.java index e9c91c8..37afb2a 100644 --- a/src/main/java/ru/bvn13/jircbot/database/services/DeferredMessageService.java +++ b/src/main/java/ru/bvn13/jircbot/database/services/DeferredMessageService.java @@ -41,7 +41,7 @@ public class DeferredMessageService { @Transactional public int forgetAllMessages(String channelName, String recipient) { AtomicInteger count = new AtomicInteger(0); - List messages = deferredMessageRepository.getDeferredMessagesByChannelNameAndRecipientAndSentOrderByDtCreated(channelName, recipient, false); + List messages = getDeferredMessagesForUser(channelName, recipient); messages.forEach(msg -> { count.set(count.get()+1); msg.setSent(true);