-sudo -u rabbitmq rabbitmqctl list_queues -p ${vhost} name messages consumers \
- | grep "${prefix}-${host}.debian.org" \
- | while read name messages consumers; do
- if [ "${name}" != "${prefix}-${host}.debian.org" ]; then
- echo "Unexpected output: ${name} ${messages} ${consumers}"
- exit 3
- fi
- if [ "${messages}" -gt 0 ] ; then
- if [ "${consumers}" -eq 0 ]; then
- echo "${host} not connected to MQ"
- exit 2
+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
+ fi
+ if [ "${messages}" -gt 0 ] ; then
+ if [ "${consumers}" -eq 0 ]; then
+ echo "${host} not connected to MQ"
+ return 2
+ fi