X-Git-Url: https://juplo.de/gitweb/?p=demos%2Fkafka%2Fdemos-kafka-payment-system-setup;a=blobdiff_plain;f=README.sh;h=b161ab546f5d6f2af9a71857f5d618c5b577657e;hp=21ee7c86556b0baea12c2ece5a1d26cea7189472;hb=732f0b041004ffd23c27cfe64f9d46dbf0a86089;hpb=f968d08bd15d6643db1878b85089bbc17f2feaff diff --git a/README.sh b/README.sh index 21ee7c8..b161ab5 100755 --- a/README.sh +++ b/README.sh @@ -26,18 +26,30 @@ docker-compose run --rm kafka kafka-topics --zookeeper zookeeper:2181 --if-not-e docker-compose up -d peter ute franz beate klaus docker-compose run --name transferlog --rm kafka kafka-console-consumer --bootstrap-server kafka:9093 --topic transfers & + while ! [[ $(http 0:8091/actuator/health 2> /dev/null | jq -r .status ) =~ "UP" ]]; do echo "Waiting for peter..."; sleep 1; done +while ! [[ $(http 0:8092/actuator/health 2> /dev/null | jq -r .status ) =~ "UP" ]]; do echo "Waiting for ute..."; sleep 1; done +while ! [[ $(http 0:8093/actuator/health 2> /dev/null | jq -r .status ) =~ "UP" ]]; do echo "Waiting for franz..."; sleep 1; done +while ! [[ $(http 0:8094/actuator/health 2> /dev/null | jq -r .status ) =~ "UP" ]]; do echo "Waiting for beate..."; sleep 1; done +while ! [[ $(http 0:8095/actuator/health 2> /dev/null | jq -r .status ) =~ "UP" ]]; do echo "Waiting for klaus..."; sleep 1; done +echo '{"id":1,"payer":1,"payee":2, "amount":10}' | http -v :8091/transfers +echo '{"id":1,"payer":1,"payee":2, "amount":10}' | http -v :8091/transfers +echo '{"id":1,"payer":1,"payee":2, "amount":10}' | http -v :8091/transfers echo '{"id":1,"payer":1,"payee":2, "amount":10}' | http -v :8091/transfers http --follow :8091/transfers/1 http -v :8091/transfers id=2 payer=2 payee=1 amount=5 http --follow :8091/transfers/2 http -v :8091/transfers id=12 payer=2 payee=1 amount=5 http -v :8091/transfers id=21 payer=2 payee=1 amount=5 +http -v :8091/transfers id=9 payer=2 payee=1 amount=5 http -v :8091/transfers id=7 payer=2 payee=1 amount=5 http -v :8091/transfers id=9 payer=2 payee=1 amount=5 +http -v :8091/transfers id=9 payer=2 payee=1 amount=5 +http -v :8091/transfers id=9 payer=2 payee=1 amount=5 http -v :8091/transfers id=13 payer=2 payee=1 amount=5 http -v :8091/transfers id=31 payer=2 payee=1 amount=5 +http -v :8091/transfers id=31 payer=2 payee=1 amount=5 http -v --follow :8091/transfers/12 http -v --follow :8091/transfers/21 http -v --follow :8091/transfers/7 @@ -46,7 +58,13 @@ http -v --follow :8091/transfers/13 http -v --follow :8091/transfers/31 docker-compose restart peter ute franz beate klaus + while ! [[ $(http 0:8091/actuator/health 2> /dev/null | jq -r .status ) =~ "UP" ]]; do echo "Waiting for peter..."; sleep 1; done +while ! [[ $(http 0:8092/actuator/health 2> /dev/null | jq -r .status ) =~ "UP" ]]; do echo "Waiting for ute..."; sleep 1; done +while ! [[ $(http 0:8093/actuator/health 2> /dev/null | jq -r .status ) =~ "UP" ]]; do echo "Waiting for franz..."; sleep 1; done +while ! [[ $(http 0:8094/actuator/health 2> /dev/null | jq -r .status ) =~ "UP" ]]; do echo "Waiting for beate..."; sleep 1; done +while ! [[ $(http 0:8095/actuator/health 2> /dev/null | jq -r .status ) =~ "UP" ]]; do echo "Waiting for klaus..."; sleep 1; done + http -v --follow :8091/transfers/1 http -v --follow :8091/transfers/2 http -v --follow :8091/transfers/12