replace stop action in messenger

bin/messenger

@@ -22,7 +22,7 @@ help() {
     -l debug|info|notice|warning|error
           Debug level
 
-	-a start|stop|restart
+	-a start|stop|restart|status
 EOH
 }
 
@@ -34,52 +34,23 @@ on_interrupt() {
 }
 
 start_messenger() {
-	started=0
-	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
+	nohup php8.1 bin/console messenger:consume 2>/dev/null >/dev/null &
+	log -t -l notice "Started"
 }
 
 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
+get_pid() {
+	pgrep -f messenger:consume
 }
 
 main() {
 	cd "$(dirname "0")"
 
-	pid_file=var/messenger.pid
+	ACTION=
 
 	while getopts "l:ha:" option; do
 		case "${option}" in
@@ -97,10 +68,12 @@ main() {
 	elif [ "$ACTION" = "restart" ]; then
 		stop_messenger
 		start_messenger
+	elif [ "$ACTION" = "status" ]; then
+		get_pid
+	else
+		log -l error "Action is required."
 	fi
 
-	# log [-t] [-l debug|info|notice|warning|error] message
-
 	exit 0
 }