diff --git a/zaqar/bench/observer.py b/zaqar/bench/observer.py
index d49a12a4..f8e65450 100644
--- a/zaqar/bench/observer.py
+++ b/zaqar/bench/observer.py
@@ -70,7 +70,8 @@ def observer(queues, stats, test_duration, limit):
 
         try:
             marktime.start('list_messages')
-            cursor = queue['q'].messages(limit=limit, marker=queue['m'])
+            cursor = queue['q'].messages(limit=limit, marker=queue['m'],
+                                         include_claimed=True)
             total_elapsed += marktime.stop('list_messages').seconds
             total_succeeded += 1