From 40aa3bfc0113413042fab3da5eb602af4094102e Mon Sep 17 00:00:00 2001
From: kgriffs <kurt.griffiths@rackspace.com>
Date: Wed, 3 Sep 2014 16:14:37 -0500
Subject: [PATCH] In benchmark observer worker, include claimed messages when
 listing

This a tiny change to make the observer behave more as you might
expect an auditing/diagnostic client to behave when obeserving
a task distribution queue.

Change-Id: Idcb8eb970c1f205b9fc7efdfeb860805b1a45640
---
 zaqar/bench/observer.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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