Add new callback called when message is put into outgoingStore.
#869
Conversation
Added new callback `cbStorePut` to `publish()`. `cbStorePut` is called when message is put into `outgoingStore`. Problem: When disconnection occures right after `publish()` but `callback` is not called, then reconnect, client can't know if the message is completely stored into `outgoingStore`. Outcome: This commit fixes above problem. Client can know that message has been put into `outgoingStore` when `cbStorePut` is called.
|
Motivation: |
README.md
Outdated
| @@ -343,7 +343,7 @@ and connections | |||
|
|
|||
| ------------------------------------------------------- | |||
| <a name="publish"></a> | |||
| ### mqtt.Client#publish(topic, message, [options], [callback]) | |||
| ### mqtt.Client#publish(topic, message, [options], [callback], [cbStorePut]) | |||
There was a problem hiding this comment.
I would prefer the new callabck to be in the option instead?
There was a problem hiding this comment.
I changed that the callback is one of publish method's options.
|
Thank you very much for merging. |
Add new callback called when message is put into `outgoingStore`.
Add new callback called when message is put into `outgoingStore`.
Added new callback
cbStorePuttopublish().cbStorePutis called when message is put intooutgoingStore.Problem:
When disconnection occures right after
publish()butcallbackis not called, then reconnect, client can't know if the message is completely stored intooutgoingStore.Outcome:
This commit fixes above problem.
Client can know that message has been put into
outgoingStorewhencbStorePutis called.