From 965956e7a1e8ca9ae9a2c3c84fec411750f9dbbe Mon Sep 17 00:00:00 2001 From: Charlie Smurthwaite Date: Fri, 23 Mar 2018 11:16:28 +0000 Subject: [PATCH] update to monitoring script --- script/queue_size.rb | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/script/queue_size.rb b/script/queue_size.rb index 6a115ae..6ae20ce 100644 --- a/script/queue_size.rb +++ b/script/queue_size.rb @@ -3,5 +3,5 @@ require_relative '../lib/postal/config' require 'mysql2' client = Mysql2::Client.new(:host => Postal.config.main_db.host, :username => Postal.config.main_db.username, :password => Postal.config.main_db.password, :port => Postal.config.main_db.port, :database => Postal.config.main_db.database) -result = client.query("SELECT COUNT(id) as size FROM `queued_messages` WHERE retry_after IS NULL OR retry_after <= ADDTIME(UTC_TIMESTAMP(), '30')") +result = client.query("SELECT COUNT(id) as size FROM `queued_messages` WHERE retry_after IS NULL OR retry_after <= ADDTIME(UTC_TIMESTAMP(), '30') AND locked_at IS NULL") puts result.to_a.first['size']