blob: 00b08d30163774e088d9b0425ea872c94456a94f (
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
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
|
#! /bin/bash
source test_env.sh
sasl_config_file=$builddir/sasl_config
my_random_number=$RANDOM
tmp_root=/tmp/sasl_fed/$my_random_number
mkdir -p $tmp_root
#--------------------------------------------------
#echo " Starting broker 1"
#--------------------------------------------------
$QPIDD_EXEC \
-p 0 \
--data-dir $tmp_root/data_1 \
--auth=yes \
--mgmt-enable=yes \
--log-enable info+ \
--log-source yes \
--log-to-file $tmp_root/qpidd_1.log \
--sasl-config=$sasl_config_file \
-d > $tmp_root/broker_1_port
broker_1_port=`cat $tmp_root/broker_1_port`
#--------------------------------------------------
#echo " Starting broker 2"
#--------------------------------------------------
$QPIDD_EXEC \
-p 0 \
--data-dir $tmp_root/data_2 \
--auth=yes \
--mgmt-enable=yes \
--log-enable info+ \
--log-source yes \
--log-to-file $tmp_root/qpidd_2.log \
--sasl-config=$sasl_config_file \
-d > $tmp_root/broker_2_port
broker_2_port=`cat $tmp_root/broker_2_port`
sleep 2
# Grep the sasl version out of broker 2's log
sasl_version=`cat $tmp_root/qpidd_2.log | grep "SASL enabled" | tr ' ' '\n' | tail -1`
# Minimum sasl version I can use is 2.1.22 == (2<<16) + (1<<8) + 22 == 131350.
if [ "$sasl_version" -lt "131350" ]; then
echo "sasl_fed test requires SASL version 2.1.22 or greater"
# but this should not cause a test failure.
exit 0
fi
# I am not randomizing these names, because the test creates its own brokers.
QUEUE_NAME=sasl_fed_queue
ROUTING_KEY=sasl_fed_queue
EXCHANGE_NAME=sasl_fedex
#--------------------------------------------------
#echo " add exchanges"
#--------------------------------------------------
$PYTHON_COMMANDS/qpid-config -a localhost:$broker_1_port add exchange direct $EXCHANGE_NAME
$PYTHON_COMMANDS/qpid-config -a localhost:$broker_2_port add exchange direct $EXCHANGE_NAME
#--------------------------------------------------
#echo " add queues"
#--------------------------------------------------
$PYTHON_COMMANDS/qpid-config -a localhost:$broker_1_port add queue $QUEUE_NAME
$PYTHON_COMMANDS/qpid-config -a localhost:$broker_2_port add queue $QUEUE_NAME
sleep 5
#--------------------------------------------------
#echo " create bindings"
#--------------------------------------------------
$PYTHON_COMMANDS/qpid-config -a localhost:$broker_1_port bind $EXCHANGE_NAME $QUEUE_NAME $ROUTING_KEY
$PYTHON_COMMANDS/qpid-config -a localhost:$broker_2_port bind $EXCHANGE_NAME $QUEUE_NAME $ROUTING_KEY
sleep 5
#--------------------------------------------------
#echo " qpid-route route add"
#--------------------------------------------------
$PYTHON_COMMANDS/qpid-route route add zag/zag@localhost:$broker_2_port zag/zag@localhost:$broker_1_port $EXCHANGE_NAME $ROUTING_KEY "" "" DIGEST-MD5
sleep 5
n_messages=100
#--------------------------------------------------
#echo " Sending 100 messages to $broker_1_port "
#--------------------------------------------------
$builddir/datagen --count $n_messages | $SENDER_EXEC --username zag --password zag --exchange $EXCHANGE_NAME --routing-key $ROUTING_KEY --port $broker_1_port
sleep 5
#--------------------------------------------------
#echo " Examine Broker $broker_1_port"
#--------------------------------------------------
broker_1_message_count=`$PYTHON_COMMANDS/qpid-stat -q localhost:$broker_1_port | grep sasl_fed_queue | awk '{print $2}'`
#echo " "
#--------------------------------------------------
#echo " Examine Broker $broker_2_port"
#--------------------------------------------------
broker_2_message_count=`$PYTHON_COMMANDS/qpid-stat -q localhost:$broker_2_port | grep sasl_fed_queue | awk '{print $2}'`
#echo " "
#--------------------------------------------------
#echo " Asking brokers to quit."
#--------------------------------------------------
$QPIDD_EXEC --port $broker_1_port --quit
$QPIDD_EXEC --port $broker_2_port --quit
#--------------------------------------------------
#echo "Removing temporary directory $tmp_root"
#--------------------------------------------------
rm -rf $tmp_root
if [ "$broker_2_message_count" -eq "$n_messages" ]; then
# echo "good: |$broker_2_message_count| == |$n_messages|"
exit 0
else
# echo "not ideal: |$broker_1_message_count| != |$n_messages|"
exit 1
fi
|
