Merge branch 'develop' into feature/halloween
This commit is contained in:
commit
488e278b04
|
@ -34,52 +34,18 @@ on_interrupt() {
|
||||||
}
|
}
|
||||||
|
|
||||||
start_messenger() {
|
start_messenger() {
|
||||||
started=0
|
nohup php8.1 bin/console messenger:consume 2>/dev/null >/dev/null &
|
||||||
pid=
|
|
||||||
|
|
||||||
if [ -f "$pid_file" ]; then
|
|
||||||
pid="$(cat "$pid_file")"
|
|
||||||
fi
|
|
||||||
|
|
||||||
if [ -n "$pid" ]; then
|
|
||||||
if [ -d "/proc/$pid" ]; then
|
|
||||||
log -t -l warning "Already running"
|
|
||||||
started=1
|
|
||||||
fi
|
|
||||||
fi
|
|
||||||
|
|
||||||
if [ "$started" -eq 0 ]; then
|
|
||||||
nohup php8.1 bin/console messenger:consume 2>/dev/null >/dev/null &
|
|
||||||
echo -n $! > "$pid_file"
|
|
||||||
log -t -l notice "Started"
|
|
||||||
fi
|
|
||||||
}
|
}
|
||||||
|
|
||||||
stop_messenger() {
|
stop_messenger() {
|
||||||
pid=
|
php8.1 bin/console messenger:stop-workers
|
||||||
|
log -t -l notice "Stopped"
|
||||||
if [ -f "$pid_file" ]; then
|
|
||||||
pid="$(cat "$pid_file")"
|
|
||||||
fi
|
|
||||||
|
|
||||||
if [ -n "$pid" ]; then
|
|
||||||
if [ ! -d "/proc/$pid" ]; then
|
|
||||||
log -t -l warning "Not started"
|
|
||||||
else
|
|
||||||
kill -9 "$pid"
|
|
||||||
log -t -l notice "Stopped"
|
|
||||||
fi
|
|
||||||
|
|
||||||
rm "$pid_file"
|
|
||||||
else
|
|
||||||
log -t -l warning "Not started"
|
|
||||||
fi
|
|
||||||
}
|
}
|
||||||
|
|
||||||
main() {
|
main() {
|
||||||
cd "$(dirname "0")"
|
cd "$(dirname "0")"
|
||||||
|
|
||||||
pid_file=var/messenger.pid
|
ACTION=
|
||||||
|
|
||||||
while getopts "l:ha:" option; do
|
while getopts "l:ha:" option; do
|
||||||
case "${option}" in
|
case "${option}" in
|
||||||
|
@ -97,10 +63,10 @@ main() {
|
||||||
elif [ "$ACTION" = "restart" ]; then
|
elif [ "$ACTION" = "restart" ]; then
|
||||||
stop_messenger
|
stop_messenger
|
||||||
start_messenger
|
start_messenger
|
||||||
|
else
|
||||||
|
log -l error "Action no defined."
|
||||||
fi
|
fi
|
||||||
|
|
||||||
# log [-t] [-l debug|info|notice|warning|error] message
|
|
||||||
|
|
||||||
exit 0
|
exit 0
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue