summaryrefslogtreecommitdiff
path: root/cpp/src/tests/cluster_failover
blob: 43170c731ad065ce58122f395e35f9d00bef2a1a (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
#!/bin/sh
# A simple manual failover test, sends a stream of numbered messages.
# You can kill the connected broker and verify that the clients reconnect 
# and no messages are lost.

URL=$1
test -n "$URL" || { echo Usage: $0 URL ; exit 1; }
SEND=$(mktemp /tmp/send.XXXXXXXXXX)
RECV=$(mktemp /tmp/recv.XXXXXXXXXX)
echo $SEND $RECV

seq 1000000 > $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