diff --git a/lib/Db/FsEventMapper.php b/lib/Db/FsEventMapper.php
index 69de0a9..93ae2b1 100644
--- a/lib/Db/FsEventMapper.php
+++ b/lib/Db/FsEventMapper.php
@@ -72,7 +72,7 @@ public function insertRow(string $type, string $userId, int $nodeId): Entity {
 	 */
 	public function getFromQueue(int $limit): array {
 		$qb = $this->db->getQueryBuilder();
-		$qb->selectDistinct(['user_id', 'type', 'node_id'])
+		$qb->selectDistinct(['id', 'user_id', 'type', 'node_id'])
 			->from($this->getTableName())
 			->setMaxResults($limit);