ackMessage.addType(AbstractMessage.QOSType.valueOf(req.qos));
}
return ackMessage;
}
private void publishRetainedMessagesInSession(final Subscription newSubscription, String username) {
<BUG>LOG.debug("Publish persisted messages in session {}", newSubscription);
Collection<IMessagesStore.StoredMessage> messages = m_messagesStore.searchMatching(new IMatchingCondition() {</BUG>
@Override
public boolean match(String key) {
return SubscriptionsStore.matchTopics(key, newSubscription.getTopicFilter());

ackMessage.addType(AbstractMessage.QOSType.valueOf(req.qos));
}
return ackMessage;
}
private void publishRetainedMessagesInSession(final Subscription newSubscription, String username) {
LOG.info("Retrieving retained messages. MqttClientId = {}, topics = {}.", newSubscription.getClientId(),
newSubscription.getTopicFilter());
Collection<IMessagesStore.StoredMessage> messages = m_messagesStore.searchMatching(new IMatchingCondition() {
@Override
public boolean match(String key) {
return SubscriptionsStore.matchTopics(key, newSubscription.getTopicFilter());
