pull/6/head
Vyacheslav N. Boyko 2018-04-09 17:22:51 +03:00
parent 3a1161d23e
commit bf825035ac
1 changed files with 1 additions and 1 deletions

View File

@ -41,7 +41,7 @@ public class DeferredMessageService {
@Transactional
public int forgetAllMessages(String channelName, String recipient) {
AtomicInteger count = new AtomicInteger(0);
List<DeferredMessage> messages = deferredMessageRepository.getDeferredMessagesByChannelNameAndRecipientAndSentOrderByDtCreated(channelName, recipient, false);
List<DeferredMessage> messages = getDeferredMessagesForUser(channelName, recipient);
messages.forEach(msg -> {
count.set(count.get()+1);
msg.setSent(true);