#! /bin/sh . ../env.sh mkdir -p log pid ./zstop.sh v= v=-v v=-q cleardb() { psql -q -d $db -c ' set client_min_messages=warning; drop schema if exists londiste cascade; drop schema if exists pgq_node cascade; drop schema if exists pgq cascade; drop table if exists mydata; drop table if exists footable; drop sequence if exists footable_id_seq; ' } run() { echo "$ $*" "$@" } for db in db1 db2 db3; do pgqadm conf/ticker_$db.ini -k cleardb $db done run ./plainconsumer.py -s conf/nop_consumer.ini rm -f log/*.log set -e run cat conf/ticker_db1.ini #echo " # pgqadm install # " run pgqadm $v conf/ticker_db1.ini install run pgqadm $v conf/ticker_db2.ini install run pgqadm $v conf/ticker_db3.ini install #echo " # pgqadm ticker # " run pgqadm $v -d conf/ticker_db1.ini ticker run pgqadm $v -d conf/ticker_db2.ini ticker run pgqadm $v -d conf/ticker_db3.ini ticker #echo " # setadm create-node # " run setadm $v --worker=node1_worker conf/setadm.ini create-root node1 'dbname=db1' run setadm $v --worker=node2_worker conf/setadm.ini create-branch node2 'dbname=db2' --provider='dbname=db1' run setadm $v --worker=node3_worker conf/setadm.ini create-branch node3 'dbname=db3' --provider='dbname=db2' #echo " # setadm status # " run setadm $v conf/setadm.ini status #echo " # plainconsumer # " run ./plainconsumer.py $v conf/nop_consumer.ini --register --provider='dbname=db1' run ./plainconsumer.py $v -d conf/nop_consumer.ini #echo " # plainworker # " run ./plainworker.py $v -d conf/worker_db1.ini run ./plainworker.py $v -d conf/worker_db2.ini run ./plainworker.py $v -d conf/worker_db3.ini #echo " # insert_event() # " run psql db1 -c "select pgq.insert_event('fooqueue', 'tmp', 'data')" run sleep 10 grep -E 'ERR|WARN|CRIT' log/*.log || true