IMessagesStore.StoredMessage pub = new IMessagesStore.StoredMessage(will.getPayload().array(), will.getQos(), will.getTopic());
pub.setRetained(will.isRetained());
return pub;
}
public void processPublish(Channel channel, PublishMessage msg) {
<BUG>LOG.info("PUB --PUBLISH--> SRV executePublish invoked with {}", msg);
final AbstractMessage.QOSType qos = msg.getQos();</BUG>
switch (qos) {
case MOST_ONE:
this.qos0PublishHandler.receivedPublishQos0(channel, msg);

IMessagesStore.StoredMessage pub = new IMessagesStore.StoredMessage(will.getPayload().array(), will.getQos(), will.getTopic());
pub.setRetained(will.isRetained());
return pub;
}
public void processPublish(Channel channel, PublishMessage msg) {
LOG.info("Processing PUBLISH message. MqttClientId = {}, topic = {}, messageId = {}, qos = {}.",
msg.getClientId(), msg.getTopicName(), msg.getMessageID(), msg.getQos());
final AbstractMessage.QOSType qos = msg.getQos();
switch (qos) {
case MOST_ONE:
this.qos0PublishHandler.receivedPublishQos0(channel, msg);
