Skip to content

Commit

Permalink
rabbitmq-ack-rate: include unacked msgs when checking priority queue
Browse files Browse the repository at this point in the history
Signed-off-by: Pavel Pulec <[email protected]>
  • Loading branch information
Pavel Pulec committed Sep 26, 2017
1 parent e2ab7db commit 2b4fbf1
Showing 1 changed file with 4 additions and 3 deletions.
7 changes: 4 additions & 3 deletions check_rabbitmq-ack-rate
Original file line number Diff line number Diff line change
Expand Up @@ -64,7 +64,6 @@ data () {

if [[ -n "${priority_queue_name}" ]];then
priority_queue_messages=$( echo $get | jq ". | map(select(.name == \"${priority_queue_name}\")) | .[].messages" -r )
priority_queue_messages_unack=$( echo $get | jq ". | map(select(.name == \"${priority_queue_name}\")) | .[].messages_unacknowledged" -r )
fi

queue_messages=$( echo $get | jq ". | map(select(.name == \"${queue_name}\")) | .[].messages" -r )
Expand All @@ -85,6 +84,9 @@ data () {
echo "Debug: messages ack: $queue_messages_ack_rate"
echo "Debug: messages get: $queue_messages_get_rate"
echo "Debug: messages noack: $queue_messages_noack_rate"
if [[ -n "${priority_queue_name}" ]];then
echo "Debug: messages in the priority queue '${priority_queue_name}': $priority_queue_messages"
fi
fi
}

Expand All @@ -98,8 +100,7 @@ do_main_check () {
fi

if [[ -n "${priority_queue_name}" ]];then
# Check if there are messages in the priority queue minus the unacked messages as we don't care about those
priority_queue_messages=$(( ${priority_queue_messages} - ${priority_queue_messages_unack} ))
# Check if there are messages in the priority queue (including unacked messages)
if (( $( echo "${priority_queue_messages} > 0" | bc -l ) ));then
message="Ok: The queue with higher priority '${priority_queue_name}' is not empty so the queue '${queue_name}' can grow."
exitstatus=0
Expand Down

0 comments on commit 2b4fbf1

Please sign in to comment.