| #!/usr/bin/env bash |
| |
| # |
| # Licensed to the Apache Software Foundation (ASF) under one |
| # or more contributor license agreements. See the NOTICE file |
| # distributed with this work for additional information |
| # regarding copyright ownership. The ASF licenses this file |
| # to you under the Apache License, Version 2.0 (the |
| # "License"); you may not use this file except in compliance |
| # with the License. You may obtain a copy of the License at |
| # |
| # http://www.apache.org/licenses/LICENSE-2.0 |
| # |
| # Unless required by applicable law or agreed to in writing, |
| # software distributed under the License is distributed on an |
| # "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| # KIND, either express or implied. See the License for the |
| # specific language governing permissions and limitations |
| # under the License. |
| # |
| |
| set -eu |
| |
| WORK_DIR=$WORK_DIR/sasl_fed |
| mkdir $WORK_DIR |
| |
| sasl_config_dir=$BUILD_DIR/src/tests/sasl_config |
| |
| # Create ACL file to allow links |
| echo acl allow all all > $WORK_DIR/sasl_fed.acl |
| |
| echo "Starting broker 1" |
| |
| qpidd \ |
| -p 0 --interface 127.0.0.1 \ |
| --data-dir $WORK_DIR/data_1 \ |
| --auth=yes \ |
| --mgmt-enable=yes \ |
| --log-enable info+ \ |
| --log-source yes \ |
| --log-to-file $WORK_DIR/qpidd_1.log \ |
| --sasl-config=$sasl_config_dir \ |
| --acl-file $WORK_DIR/sasl_fed.acl \ |
| -d > $WORK_DIR/broker_1_port |
| |
| broker_1_port=$(cat $WORK_DIR/broker_1_port) |
| |
| echo "Starting broker 2" |
| |
| qpidd \ |
| -p 0 --interface 127.0.0.1 \ |
| --data-dir $WORK_DIR/data_2 \ |
| --auth=yes \ |
| --mgmt-enable=yes \ |
| --log-enable info+ \ |
| --log-source yes \ |
| --log-to-file $WORK_DIR/qpidd_2.log \ |
| --sasl-config=$sasl_config_dir \ |
| --acl-file $WORK_DIR/sasl_fed.acl \ |
| -d > $WORK_DIR/broker_2_port |
| |
| broker_2_port=$(cat $WORK_DIR/broker_2_port) |
| |
| function stop_brokers { |
| qpidd --port $broker_1_port --quit |
| qpidd --port $broker_2_port --quit |
| } |
| |
| trap stop_brokers EXIT |
| |
| sleep 2 |
| |
| # 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 "Adding exchanges" |
| |
| qpid-config -b localhost:$broker_1_port add exchange direct $EXCHANGE_NAME |
| qpid-config -b localhost:$broker_2_port add exchange direct $EXCHANGE_NAME |
| |
| echo "Adding queues" |
| |
| qpid-config -b localhost:$broker_1_port add queue $QUEUE_NAME |
| qpid-config -b localhost:$broker_2_port add queue $QUEUE_NAME |
| |
| sleep 5 |
| |
| echo "Creating bindings" |
| |
| qpid-config -b localhost:$broker_1_port bind $EXCHANGE_NAME $QUEUE_NAME $ROUTING_KEY |
| qpid-config -b localhost:$broker_2_port bind $EXCHANGE_NAME $QUEUE_NAME $ROUTING_KEY |
| |
| sleep 5 |
| |
| echo "Adding routes" |
| |
| 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 " |
| |
| datagen --count $n_messages | sender --mechanism DIGEST-MD5 --username zag --password zag --exchange $EXCHANGE_NAME --routing-key $ROUTING_KEY --port $broker_1_port |
| |
| sleep 5 |
| |
| echo "Examining Broker $broker_1_port" |
| |
| broker_1_message_count=$(qpid-stat -q -b localhost:$broker_1_port | grep sasl_fed_queue | awk '{print $2}') |
| |
| echo "Examining Broker $broker_2_port" |
| |
| broker_2_message_count=$(qpid-stat -q -b localhost:$broker_2_port | grep sasl_fed_queue | awk '{print $2}') |
| |
| if (( $broker_2_message_count != $n_messages )); then |
| echo "Expected ${n_messages} and received ${broker_2_message_count}" |
| exit 1 |
| fi |