return null;
}
ClientSession clientSession = m_sessionsStore.sessionForClient(msg.getClientID());
boolean isSessionAlreadyStored = clientSession != null;
if (!isSessionAlreadyStored) {
<BUG>LOG.debug("Create persistent session for clientID <{}>", msg.getClientID());</BUG>
clientSession = m_sessionsStore.createNewSession(msg.getClientID(), msg.isCleanSession());
}
<BUG>if (msg.isCleanSession()) {
clientSession.cleanSession();</BUG>
}

return null;
}
ClientSession clientSession = m_sessionsStore.sessionForClient(msg.getClientID());
boolean isSessionAlreadyStored = clientSession != null;
if (!isSessionAlreadyStored) {
clientSession = m_sessionsStore.createNewSession(msg.getClientID(), msg.isCleanSession());
