summaryrefslogtreecommitdiff
path: root/qpid/cpp/src/tests/replication_test
diff options
context:
space:
mode:
authorCarl C. Trieloff <cctrieloff@apache.org>2009-07-31 13:45:59 +0000
committerCarl C. Trieloff <cctrieloff@apache.org>2009-07-31 13:45:59 +0000
commite5ef7170e78edde6bc0a7a3098a821e9701be8d1 (patch)
treec7373adee60681da14efd71bba00e6cb092a2797 /qpid/cpp/src/tests/replication_test
parentca88c98484377d46ca4d4c23a6f0dd2fbe291111 (diff)
downloadqpid-python-e5ef7170e78edde6bc0a7a3098a821e9701be8d1.tar.gz
Candidate fix for race condition in test
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@799609 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/tests/replication_test')
-rwxr-xr-xqpid/cpp/src/tests/replication_test5
1 files changed, 4 insertions, 1 deletions
diff --git a/qpid/cpp/src/tests/replication_test b/qpid/cpp/src/tests/replication_test
index 3a0d94e0c4..5ae4cf7806 100755
--- a/qpid/cpp/src/tests/replication_test
+++ b/qpid/cpp/src/tests/replication_test
@@ -122,7 +122,8 @@ if test -d ${PYTHON_DIR} && test -f ../.libs/replicating_listener.so && test -f
$PYTHON_DIR/commands/qpid-config -a "localhost:$BROKER_A" add queue queue-e --generate-queue-events 2
$PYTHON_DIR/commands/qpid-config -a "localhost:$BROKER_B" add queue queue-e
- $PYTHON_DIR/commands/qpid-config -a "localhost:$BROKER_A" add queue queue-d --generate-queue-events 2
+ $PYTHON_DIR/commands/qpid-config -a "localhost:$BROKER_A" add queue queue-d --generate-queue-events 1
+ $PYTHON_DIR/commands/qpid-config -a "localhost:$BROKER_B" add queue queue-d
i=1
while [ $i -le 10 ]; do
@@ -133,6 +134,8 @@ if test -d ${PYTHON_DIR} && test -f ../.libs/replicating_listener.so && test -f
./sender --port $BROKER_A --routing-key queue-e --send-eos 1 < queue-e-input.repl
./receiver --port $BROKER_A --queue queue-e --messages 10 > /dev/null
# now check offsets working
+ echo dummy | ./sender --port $BROKER_A --routing-key queue-d --send-eos 1
+ ./receiver --port $BROKER_B --queue queue-d --messages 1 > /dev/null
../qpidd -q --port $BROKER_B
unset BROKER_B