1 files changed, 3 insertions, 2 deletions
diff --git a/lib/top_block_query.cpp b/lib/top_block_query.cpp
index 96e2847..09a3d10 100644
--- a/lib/top_block_query.cpp
+++ b/lib/top_block_query.cpp
@@ -75,8 +75,9 @@ static std::string query_stats(ElementImpl *self, const boost::property_tree::pt
         if (std::find(block_ids.begin(), block_ids.end(), id) == block_ids.end()) continue;
 
         //send a message to the block's actor to query stats
-        dynamic_cast<BlockActor *>(worker)->highPrioPreNotify();
-        worker->Push(GetStatsMessage(), receiver.GetAddress());
+        GetStatsMessage message;
+        message.prio_token = dynamic_cast<BlockActor *>(worker)->prio_token;
+        worker->Push(message, receiver.GetAddress());
         outstandingCount++;
     }
     while (outstandingCount) outstandingCount -= receiver.Wait(outstandingCount);