diff --git a/sgx_jmp.rb b/sgx_jmp.rb index fa7c3593b8afaaa23f4c61254beb76ddc212ffd1..3e2f22d9693ff1e6a9fef50c8aa67b5324f11fd6 100644 --- a/sgx_jmp.rb +++ b/sgx_jmp.rb @@ -223,14 +223,16 @@ when_ready do DB = Postgres.connect(dbname: "jmp", size: 5) TEL_SELECTIONS = TelSelections.new - DB.hold do |conn| - conn.query("LISTEN low_balance") - conn.query("LISTEN possible_renewal") - catchup_notify_low_balance(conn) - catchup_notify_possible_renewal(conn) - - repo = CustomerRepo.new(sgx_repo: Bwmsgsv2Repo.new) - poll_for_notify(conn, repo) + EMPromise.resolve(nil).then do + DB.hold do |conn| + conn.query("LISTEN low_balance") + conn.query("LISTEN possible_renewal") + catchup_notify_low_balance(conn) + catchup_notify_possible_renewal(conn) + + repo = CustomerRepo.new(sgx_repo: Bwmsgsv2Repo.new) + poll_for_notify(conn, repo).sync + end end load_plans_to_db!