diff --git a/sgx_jmp.rb b/sgx_jmp.rb index 5c65377cfd53f721b3905518b2d39a17e38f5d76..43ece2fa120fb335982958812e45a5d4359b9ff1 100644 --- a/sgx_jmp.rb +++ b/sgx_jmp.rb @@ -153,7 +153,7 @@ EM.error_handler(&method(:panic)) def poll_for_notify(db) db.wait_for_notify_defer.then { |notify| - Customer.for_customer_id(notify[:extra]) + CustomerRepo.new.find(notify[:extra]) }.then(&LowBalance.method(:for)).then(&:notify!).then { poll_for_notify(db) }.catch(&method(:panic))