blob: 9271d8d972187721d8b60685f81480e5f712b3fa (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
|
#!/bin/sh
# Run from the installed examples/ dir with a full path to this script.
# If $QPIDD is set, run a private QPIDD and use it.
# If $QPID_HOST or $QPID_PORT are set, use them to connect.
DIR=$PWD
SRC=`dirname $0 | sed 's|^\([^/].*\)|'$PWD'/\1|'`/examples
# Start private broker if QPIDD is set.
if [ -n "$QPIDD" ] ; then
export QPID_PORT=`$QPIDD -dp0` || { echo "Cannot start $QPIDD" ; exit 1; }
trap "$QPIDD -q" EXIT
fi
cleanup() {
test -n "$QPIDD" && $QPIDD -q # Private broker
kill %% > /dev/null 2>&1 # Leftover background jobs
}
trap cleanup EXIT
ARGS="${QPID_HOST:-localhost} $QPID_PORT"
client() { "$@" $ARGS > $1.out; }
clients() { for cmd in "$@"; do client $cmd; done; }
waitfor() { until grep -a -l "$2" $1 >/dev/null 2>&1 ; do sleep 1 ; done ; }
background() {
pattern=$1; shift
eval "$@ $ARGS > $1.out &"
waitfor $1.out $pattern
}
outputs() {
wait 2> /dev/null # Wait for all backgroud processes to complete
for f in "$@"; do
{ echo "==== $f"; eval "cat $f"; } >> verify.out ;
done
}
verify() {
dir=$1
func=`echo $dir | tr - _`
cd $dir || return 1
rm -f *.out
{ $func && diff -ac verify.out $SRC/$dir/verify.in ; } || return 1
rm -f *.out
}
HEX="[a-fA-F0-9]"
remove_uuid() {
sed "s/$HEX\{8\}-$HEX\{4\}-$HEX\{4\}-$HEX\{4\}-$HEX\{12\}//g" $*
}
# Scripts for each example
direct() {
clients ./declare_queues ./direct_producer ./listener
outputs ./declare_queues.out ./direct_producer.out ./listener.out
}
fanout() {
clients ./declare_queues ./fanout_producer ./listener
outputs ./declare_queues.out ./fanout_producer.out ./listener.out
}
pub_sub() {
background "Listening" ./topic_listener
clients ./topic_publisher
outputs ./topic_publisher.out "topic_listener.out | remove_uuid | sort"
}
request_response() {
background "Waiting" ./server
clients ./client
kill %% # Must kill the server.
outputs "./client.out | remove_uuid" " server.out | remove_uuid"
}
# Main
EXAMPLES=${*:-direct fanout pub-sub request-response}
for ex in $EXAMPLES ; do
if ( verify $ex; ) then echo "PASS: $ex"; else
echo "FAIL: $ex"; RET=1; fi
done
exit $RET
|
