diff --git a/sgx_jmp.rb b/sgx_jmp.rb index d222cbafebaf5049e6d1bda51d460d5d5bbb77a6..4e3837270fc96ea8cedbcdf96e4762e264fe434e 100644 --- a/sgx_jmp.rb +++ b/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)