If there is an issue reading/processing an item from the queue (e.g. the packet written to disk is corrupt) then `autopaho enters an infinite loop attempting to send the same packet.
To reproduce
Use autopaho/queue/file and create a zero byte file matching the queue pattern; run autopaho with the queue.
Debug output
Same error repeated over and over.
Expected behaviour
Move the file to an error queue (or for memory queue probably just delete it).
Describe the bug
If there is an issue reading/processing an item from the queue (e.g. the packet written to disk is corrupt) then `autopaho enters an infinite loop attempting to send the same packet.
To reproduce Use
autopaho/queue/fileand create a zero byte file matching the queue pattern; run autopaho with the queue.Debug output Same error repeated over and over.
Expected behaviour Move the file to an error queue (or for memory queue probably just delete it).
Software used: @master 01a446ef22f07223ca22e6e533f6a277e0ba8585
Additional context Same issue with
pahostores (will del with queue first).