moscajs / mosca

MQTT broker as a module
mosca.io
3.2k stars 513 forks source link

server.deleteOfflinePacket() #757

Open AreenRao opened 6 years ago

AreenRao commented 6 years ago

this.inflightCounter--; delete this.inflight[packet.messageId];

this.server.deleteOfflinePacket(this, packet.messageId, function(err) { } does this function delete all the messages in 'inFlight' whose messageId matches to 'packet.messageId' sent in this function. Or this deletes only one message.