diff --git a/src/Message/ExpressConsumeUndoRequest.php b/src/Message/ExpressConsumeUndoRequest.php
index 25bdac0..e632708 100644
--- a/src/Message/ExpressConsumeUndoRequest.php
+++ b/src/Message/ExpressConsumeUndoRequest.php
@@ -52,7 +52,7 @@ public function getData()
 
     public function getQueryId()
     {
-        $this->getParameter('queryId');
+        return $this->getParameter('queryId');
     }