diff --git a/pkg/dbal/DbalConsumer.php b/pkg/dbal/DbalConsumer.php
index 69b11dbb0..a45529731 100644
--- a/pkg/dbal/DbalConsumer.php
+++ b/pkg/dbal/DbalConsumer.php
@@ -155,7 +155,7 @@ protected function receiveMessage()
 
             // remove message
             $affectedRows = $this->dbal->delete($this->context->getTableName(), ['id' => $dbalMessage['id']], [
-                'id' => Type::INTEGER,
+                'id' => Type::GUID,
             ]);
 
             if (1 !== $affectedRows) {