Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix npe in long time failing ci JournalDurableSubscriptionTest

This commit is contained in:
gtully 2018-07-04 10:40:31 +01:00
parent 83514ef799
commit 3ea18f4ed1
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
activemq-jdbc-store/src/main/java/org/apache/activemq/store/journal/JournalTopicMessageStore.java
View File

@ -188,8 +188,10 @@ public class JournalTopicMessageStore extends JournalMessageStore implements Top
while (iterator.hasNext()) {
SubscriptionKey subscriptionKey = iterator.next();
MessageId identity = cpAckedLastAckLocations.get(subscriptionKey);
MessageAck ack = new MessageAck();
ack.setMessageID(identity);
longTermStore.acknowledge(transactionTemplate.getContext(), subscriptionKey.clientId,
subscriptionKey.subscriptionName, identity, null);
subscriptionKey.subscriptionName, identity, ack);
}
}