notid/integreat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

minor fix

Browse Source
This commit is contained in:
Bryce Covert
2021-12-18 22:32:34 -08:00
parent 1488d8118a
commit be31c7164b
3 changed files with 8 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/clj/auto_ap/background/requests.clj
View File

@@ -8,10 +8,13 @@
[auto-ap.intuit.import :as i]
[unilog.context :as lc]))
(def queue-url (:requests-queue-url env))
(defn process-1 []
(lc/with-context {:source "Request poller"}
(log/info "Checking SQS...")
(let [[{:keys [message-id receipt-handle body]}] (:messages (sqs/receive-message {:queue-url (:requests-queue-url env)
(let [[{:keys [message-id receipt-handle body]}] (:messages (sqs/receive-message {:queue-url queue-url
:wait-time-seconds 1
:count 1}))]
(when message-id
(log/infof "processing message %s with body %s" message-id body )
@@ -20,7 +23,7 @@
(i/upsert-transactions)
(catch Exception e
(log/error e))))
(sqs/delete-message {:queue-url (:requests-queue-url env)
(sqs/delete-message {:queue-url queue-url
:receipt-handle receipt-handle} )))))
(defn fake-message []
@@ -28,5 +31,5 @@
:message-body ":intuit"} ))
(mount/defstate request-listener
:start (scheduler/every (* 1000 5) process-1)
:start (scheduler/every (* 1000 30) process-1)
:stop (scheduler/stop request-listener))