From 02b0ce4c311580b3f945e0a16cdabf8de8142e3d Mon Sep 17 00:00:00 2001
From: Gordon Sim <gsim@apache.org>
Date: Mon, 28 Sep 2009 12:12:41 +0000
Subject: QPID-2102: Changed QueuePolicy to rely on external locking and
 require dequeues to be handled by policy user rather.            (r817742
 introduced a deadlock in ring queue policy which this checkin fixes)

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@819505 13f79535-47bb-0310-9956-ffa450edef68
---
 qpid/cpp/src/tests/ring_queue_test | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

(limited to 'qpid/cpp/src/tests/ring_queue_test')

diff --git a/qpid/cpp/src/tests/ring_queue_test b/qpid/cpp/src/tests/ring_queue_test
index 5805989d7e..553746eb49 100755
--- a/qpid/cpp/src/tests/ring_queue_test
+++ b/qpid/cpp/src/tests/ring_queue_test
@@ -48,7 +48,7 @@ receive() {
 
 cleanup() {
     rm -f sender_${QUEUE_NAME}_* receiver_${QUEUE_NAME}_*
-    qpid-config $BROKER_URL add queue $QUEUE_NAME
+    qpid-config $BROKER_URL del queue $QUEUE_NAME --force
 }
 
 log() {
@@ -64,10 +64,11 @@ validate() {
     if [[ $RECEIVERS -eq 0 ]]; then 
         #queue should have $LIMIT messages on it, but need to send an eos also
         sender --routing-key $QUEUE_NAME --send-eos 1 < /dev/null
-        if [[ $(receiver --queue $QUEUE_NAME --browse | wc -l) -eq $(( $LIMIT - 1)) ]]; then
+        received=$(receiver --queue $QUEUE_NAME --browse | wc -l)
+        if [[ received -eq $(( $LIMIT - 1)) ]]; then
             log "queue contains $LIMIT messages as expected"
         else
-            fail "queue does not contain the expected $LIMIT messages"
+            fail "queue does not contain the expected $LIMIT messages (received $received)"
         fi        
     elif [[ $CONCURRENT -eq 0 ]]; then
         #sum of length of all output files should be equal to $LIMIT - $RECEIVERS (1 eos message each)
-- 
cgit v1.2.1