Commit 6f6195c1 authored by wentao.suo's avatar wentao.suo

edit rabbitmq sh

parent 90ced6c6
...@@ -16,54 +16,44 @@ nohup /usr/sbin/rabbitmq-server > /tmp/rabbitmq.out & ...@@ -16,54 +16,44 @@ nohup /usr/sbin/rabbitmq-server > /tmp/rabbitmq.out &
export NAMESPACE=`cat /var/run/secrets/kubernetes.io/serviceaccount/namespace` export NAMESPACE=`cat /var/run/secrets/kubernetes.io/serviceaccount/namespace`
count=1 count=1
until [[ $count -eq 300 ]] || [[ $is_running -eq 1 ]] is_running=0
until [[ is_running -eq 1 ]]
do do
let count+=1 echo "wait rabbitmq start flag"
echo "count is $count"
curl -X GET -H "Authorization: Basic cWE6cWF0ZXN0" "http://localhost:15672/api/definitions"
if [ $? -eq 0 ]
then
echo "rabbitmq is running rabbitmq-plugins enable rabbitmq_delayed_message_exchange"
rabbitmq-plugins enable rabbitmq_delayed_message_exchange
curl --request POST \
--url http://192.168.6.13/api/etcd/set_env_job_status \
--header 'Content-Type: application/json' \
--data "{\"namespace\": \"$NAMESPACE\",\"job_name\": \"rabbitmq_sync\",\"status\": \"pending\"}"
# wailt rabbitmq start
for ((i=0;;))
do
num=`grep -n -E 'Server startup complete' /tmp/rabbitmq.out |cut -d ":" -f 1` num=`grep -n -E 'Server startup complete' /tmp/rabbitmq.out |cut -d ":" -f 1`
echo "----$num"
if [ -n "$num" ];then if [ -n "$num" ];then
is_running=1 is_running=1
break break
fi fi
sleep 10 sleep 10
done done
if [[ $is_running -eq 1 ]] echo "wait 5s"
then sleep 5
echo "rabbitmq is running!!! start execution sync job"
echo "init rabbit with eos server"
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
else
echo "rabbitmq is not running!!! Do not execution sync job"
fi
curl --request POST \ rabbitmq-plugins enable rabbitmq_delayed_message_exchange
curl --request POST \
--url http://192.168.6.13/api/etcd/set_env_job_status \
--header 'Content-Type: application/json' \
--data "{\"namespace\": \"$NAMESPACE\",\"job_name\": \"rabbitmq_sync\",\"status\": \"pending\"}"
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
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\": \"done\"}" --data "{\"namespace\": \"$NAMESPACE\",\"job_name\": \"rabbitmq_sync\",\"status\": \"done\"}"
tail -f /tmp/rabbitmq.out
else tail -f /tmp/rabbitmq.out
echo "rabbitmq is not running"
sleep 1
fi
done
......
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