jessequ
/
AMQP-CPP
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

empty queue on error

This commit is contained in:
Michael van der Werve 2020-10-15 09:35:27 +02:00
parent 2e49fd1220
commit 5af76d874e
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/throttle.cpp
View File

@ -98,6 +98,9 @@ bool Throttle::send(uint64_t id, const Frame &frame)
*/ */
void Throttle::reportError(const char *message) void Throttle::reportError(const char *message)
{ {
// assign empty queue
_queue = {};
// if a callback is set, call the handler with the message // if a callback is set, call the handler with the message
if (_errorCallback) _errorCallback(message); if (_errorCallback) _errorCallback(message);
} }