X-Git-Url: https://git.adam-barratt.org.uk/?a=blobdiff_plain;f=dsa-nagios-checks%2Fchecks%2Fdsa-check-mq-connection;h=2ed45ca4ac7a7c621c60e5a002cbecd92f044ab4;hb=986e59c71906e609f9d2c523e685365c3a3dcfc3;hp=96fe26ab429e16de24f22f30247298336f6f06b3;hpb=1f0246a8ea0f4263d90d0ffce30950dd52af790f;p=mirror%2Fdsa-nagios.git

diff --git a/dsa-nagios-checks/checks/dsa-check-mq-connection b/dsa-nagios-checks/checks/dsa-check-mq-connection
index 96fe26a..2ed45ca 100755
--- a/dsa-nagios-checks/checks/dsa-check-mq-connection
+++ b/dsa-nagios-checks/checks/dsa-check-mq-connection
@@ -61,10 +61,10 @@ if [ "${prefix/[^a-z0-9-]/}" != "$prefix" ]; then
 	exit 3
 fi
 
-check_conn () {
-	sudo -u rabbitmq rabbitmqctl list_queues -p ${vhost} name messages consumers \
-		| grep "${prefix}-${host}.debian.org" \
-		| while read name messages consumers; do
+check_output() {
+	found=0
+	while read name messages consumers; do
+		found=1
 		if [ "${name}" != "${prefix}-${host}.debian.org" ]; then
 			echo "Unexpected output: ${name} ${messages} ${consumers}"
 			return 3
@@ -75,7 +75,23 @@ check_conn () {
 				return 2
 			fi
 		fi
+		return 0
 	done
+	if [ $found = 0 ]; then
+		return 2
+	fi
+}
+
+check_conn () {
+	sudo -u rabbitmq rabbitmqctl list_queues -p ${vhost} name messages consumers \
+		| grep "${prefix}-${host}.debian.org" \
+		| check_output
+	ret=$?
+	if [ $ret != 0 ]; then
+		echo "${host} not connected to MQ"
+		return 2
+	fi
+	return 0
 }
 check_conn
 ret=$?