sgx_jmp.rb 🔗
@@ -171,7 +171,7 @@ when_ready do
DB.hold do |conn|
conn.query("LISTEN low_balance")
- conn.query("SELECT customer_id FROM balances WHERE balance <= 5").each do |c|
+ conn.query("SELECT customer_id FROM balances WHERE balance < 5").each do |c|
conn.query("SELECT pg_notify('low_balance', $1)", c.values)
end
poll_for_notify(conn)