Commit b8cf76e8 authored by wentao.suo's avatar wentao.suo

edit rabbitmq sh

parent 507800f0
#!/bin/bash #!/bin/bash
if [[ -e /.firstrun ]]; then if [[ -e /.firstrun ]]; then
/scripts/init_script.sh /scripts/init_script.sh
fi fi
...@@ -11,11 +12,11 @@ echo "Starting RabbitMQ..." ...@@ -11,11 +12,11 @@ echo "Starting RabbitMQ..."
nohup /usr/sbin/rabbitmq-server > /tmp/rabbitmq.out & nohup /usr/sbin/rabbitmq-server > /tmp/rabbitmq.out &
export NAMESPACE=`cat /var/run/secrets/kubernetes.io/serviceaccount/namespace`
function wait(){ count=1
count=1 until [[ $count -eq 300 ]] || [[ $is_running -eq 1 ]]
until [[ $count -eq 300 ]] || [[ $is_running -eq 1 ]] do
do
let count+=1 let count+=1
echo "count is $count" echo "count is $count"
curl -X GET -H "Authorization: Basic cWE6cWF0ZXN0" "http://localhost:15672/api/definitions" curl -X GET -H "Authorization: Basic cWE6cWF0ZXN0" "http://localhost:15672/api/definitions"
...@@ -25,32 +26,18 @@ function wait(){ ...@@ -25,32 +26,18 @@ function wait(){
echo "rabbitmq is running rabbitmq-plugins enable rabbitmq_delayed_message_exchange" echo "rabbitmq is running rabbitmq-plugins enable rabbitmq_delayed_message_exchange"
rabbitmq-plugins enable rabbitmq_delayed_message_exchange rabbitmq-plugins enable rabbitmq_delayed_message_exchange
tail -f /tmp/rabbitmq.out
else
echo "rabbitmq is not running"
sleep 1
fi
done
}
function sync_config(){
count=1
is_running=0
export NAMESPACE=`cat /var/run/secrets/kubernetes.io/serviceaccount/namespace`
curl --request POST \ curl --request POST \
--url http://192.168.6.13/api/etcd/set_env_job_status \ --url http://192.168.6.13/api/etcd/set_env_job_status \
--header 'Content-Type: application/json' \ --header 'Content-Type: application/json' \
--data "{\"namespace\": \"$NAMESPACE\",\"job_name\": \"rabbitmq_sync\",\"status\": \"pending\"}" --data "{\"namespace\": \"$NAMESPACE\",\"job_name\": \"rabbitmq_sync\",\"status\": \"pending\"}"
count_wait=1
until [[ $count -eq 300 ]] || [[ $is_running -eq 1 ]] is_running=0
until [[ $count_wait -eq 300 ]] || [[ $is_running -eq 1 ]]
do do
let count+=1 let count_wait+=1
echo "count is $count" echo "count_wait is count_wait"
curl -X GET -H "Authorization: Basic cWE6cWF0ZXN0" "http://rabbitmq:15672/api/definitions" curl -X GET -H "Authorization: Basic cWE6cWF0ZXN0" "http://localhost:15672/api/definitions"
if [ $? -eq 0 ] if [ $? -eq 0 ]
then then
...@@ -69,7 +56,7 @@ function sync_config(){ ...@@ -69,7 +56,7 @@ function sync_config(){
# echo "get definitions from 172.16.1.231" # echo "get definitions from 172.16.1.231"
# response=$(curl -X GET -H "Authorization: Basic cmFiYml0X2FkbWluOmFiYzEyMzQ=" "http://172.16.1.231:15672/api/definitions") # response=$(curl -X GET -H "Authorization: Basic cmFiYml0X2FkbWluOmFiYzEyMzQ=" "http://172.16.1.231:15672/api/definitions")
# curl -X POST -H "Content-Type: application/json" -H "Authorization: Basic cWE6cWF0ZXN0" -d $response "http://rabbitmq:15672/api/definitions" # curl -X POST -H "Content-Type: application/json" -H "Authorization: Basic cWE6cWF0ZXN0" -d $response "http://rabbitmq:15672/api/definitions"
response=$(curl -X POST -H "Content-Type: application/json" -d "{\"namespace\":\"$NAMESPACE\"}" "http://eos.quantgroups.com/api/etcd/init_env_rabbitmq_config") response=$(curl -X POST -H "Content-Type: application/json" -d "{\"namespace\":\"$NAMESPACE\"}" "http://192.168.6.13/api/etcd/init_env_rabbitmq_config")
echo $response echo $response
else else
echo "rabbitmq is not running!!! Do not execution sync job" echo "rabbitmq is not running!!! Do not execution sync job"
...@@ -80,10 +67,13 @@ function sync_config(){ ...@@ -80,10 +67,13 @@ function sync_config(){
--header 'Content-Type: application/json' \ --header 'Content-Type: application/json' \
--data "{\"namespace\": \"$NAMESPACE\",\"job_name\": \"rabbitmq_sync\",\"status\": \"done\"}" --data "{\"namespace\": \"$NAMESPACE\",\"job_name\": \"rabbitmq_sync\",\"status\": \"done\"}"
} tail -f /tmp/rabbitmq.out
else
echo "rabbitmq is not running"
sleep 1
fi
done
wait
sync_config
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment