diff --git a/src/asyncrpcqueue.cpp b/src/asyncrpcqueue.cpp
index 679f861c5..4cc9336c7 100644
--- a/src/asyncrpcqueue.cpp
+++ b/src/asyncrpcqueue.cpp
@@ -145,3 +145,13 @@ void AsyncRPCQueue::addWorker() {
 int AsyncRPCQueue::getNumberOfWorkers() {
     return workers.size();
 }
+
+
+std::vector<AsyncRPCOperationId> AsyncRPCQueue::getAllOperationIds() {
+    std::unique_lock< std::mutex > guard(cs_lock);
+    std::vector<AsyncRPCOperationId> v;
+    for(auto & entry: operationMap)
+        v.push_back(entry.first);
+    return v;
+}
+
diff --git a/src/asyncrpcqueue.h b/src/asyncrpcqueue.h
index 99ba45f91..f86c4f848 100644
--- a/src/asyncrpcqueue.h
+++ b/src/asyncrpcqueue.h
@@ -43,6 +43,7 @@ public:
     std::shared_ptr<AsyncRPCOperation> getOperationForId(AsyncRPCOperationId);
     std::shared_ptr<AsyncRPCOperation> popOperationForId(AsyncRPCOperationId);
     void addOperation(const std::shared_ptr<AsyncRPCOperation> &ptrOperation);
+    std::vector<AsyncRPCOperationId> getAllOperationIds();
 
 private:
     // addWorker() will spawn a new thread on this method