summaryrefslogtreecommitdiff
path: root/qpid/cpp/src/tests/cluster_failover
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/cpp/src/tests/cluster_failover')
-rwxr-xr-xqpid/cpp/src/tests/cluster_failover9
1 files changed, 5 insertions, 4 deletions
diff --git a/qpid/cpp/src/tests/cluster_failover b/qpid/cpp/src/tests/cluster_failover
index c978ee910c..43170c731a 100755
--- a/qpid/cpp/src/tests/cluster_failover
+++ b/qpid/cpp/src/tests/cluster_failover
@@ -1,6 +1,6 @@
#!/bin/sh
# A simple manual failover test, sends a stream of numbered messages.
-# You can kill the connected broker and verify that the client reconnects
+# You can kill the connected broker and verify that the clients reconnect
# and no messages are lost.
URL=$1
@@ -11,8 +11,9 @@ echo $SEND $RECV
seq 1000000 > $SEND
-qpid-receive -f -a 'q;{create:always}' -b $URL --connection-options "{reconnect:true}" | tee $RECV &
-
-qpid-send -a 'q;{create:always}' -b $URL --connection-options "{reconnect:true}" --send-rate 10 --content-stdin < $SEND &
+qpid-send -a 'cluster_failover;{create:always}' -b $URL --connection-options "{reconnect:true}" --send-rate 10 --content-stdin < $SEND &
+while msg=$(qpid-receive -m1 -f -a 'cluster_failover;{create:always}' -b $URL --connection-options "{reconnect:true,heartbeat:1}"); do
+ echo -n $msg; date
+done
wait