mirror of
https://github.com/eclipse/paho.mqtt-sn.embedded-c.git
synced 2025-12-13 15:36:51 +01:00
@@ -122,7 +122,7 @@ void MQTTGWPublishHandler::handlePublish(Client* client, MQTTGWPacket* packet)
|
|||||||
|
|
||||||
if (id > 0)
|
if (id > 0)
|
||||||
{
|
{
|
||||||
/* create REGACK */
|
/* create REGISTER */
|
||||||
MQTTSNPacket* regPacket = new MQTTSNPacket();
|
MQTTSNPacket* regPacket = new MQTTSNPacket();
|
||||||
|
|
||||||
MQTTSNString topicName;
|
MQTTSNString topicName;
|
||||||
@@ -143,6 +143,7 @@ void MQTTGWPublishHandler::handlePublish(Client* client, MQTTGWPacket* packet)
|
|||||||
(uint8_t) pub.header.bits.retain, (uint16_t) pub.msgId, topicId, (uint8_t*) pub.payload,
|
(uint8_t) pub.header.bits.retain, (uint16_t) pub.msgId, topicId, (uint8_t*) pub.payload,
|
||||||
pub.payloadlen);
|
pub.payloadlen);
|
||||||
client->getWaitREGACKPacketList()->setPacket(snPacket, regackMsgId);
|
client->getWaitREGACKPacketList()->setPacket(snPacket, regackMsgId);
|
||||||
|
return;
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
|
|||||||
Reference in New Issue
Block a user