Throttle notification processing to prevent starvation
1 files changed, 1 insertions(+), 1 deletions(-) M sgx_jmp.rb
M sgx_jmp.rb => sgx_jmp.rb +1 -1
@@ 210,7 210,7 @@ def poll_for_notify(db) DbNotification.for(notify, customer, repo) end }.then(&:call).then { - poll_for_notify(db) + EM.add_timer(0.5) { poll_for_notify(db) } }.catch(&method(:panic)) end