Clear the operation queue when closing it.

diff --git a/src/asyncrpcqueue.cpp b/src/asyncrpcqueue.cpp
index a63619f0be274f307870367797a6d2c139076c29..385709a618d22e87329d0d411635ba7f87759b0f 100644 (file)
--- a/src/asyncrpcqueue.cpp
+++ b/src/asyncrpcqueue.cpp
@@ -34,6 +34,9 @@ void AsyncRPCQueue::run(size_t workerId) {
 
             // Exit if the queue is closing.
             if (isClosed()) {
+                while (!operation_id_queue_.empty()) {
+                    operation_id_queue_.pop();
+                }
                 break;
             }