Background Jobs

;; Handlers receive an args map, return a result map
(defn send-welcome-email [args]
  (let [{:keys [user-id email]} args]
    (email/send! {:to email :subject "Welcome!"})
    {:success? true :result {:sent-to email}}))

;; A failing handler
(defn process-payment [args]
  {:success? false
   :error {:message "Payment gateway unavailable" :type "GatewayError"}})

(require '[boundary.jobs.shell.worker :as worker]
         '[boundary.jobs.ports :as ports])

(def registry (worker/create-job-registry))
(ports/register-handler! registry :send-welcome-email send-welcome-email)
(ports/register-handler! registry :process-payment process-payment)

(require '[boundary.jobs.core.job :as job])

(let [new-job (job/create-job {:job-type  :send-welcome-email
                                :args      {:user-id  (random-uuid)
                                            :email    "alice@example.com"}
                                :priority  :high
                                :max-retries 3}
                               (random-uuid))]
  (ports/enqueue-job! job-queue :default new-job))

;; Single worker
(def worker (worker/create-worker
              {:queue-name :default :poll-interval-ms 1000}
              queue store registry))

;; Worker pool (recommended for production)
(def pool (worker/create-worker-pool
            {:queue-name :default :worker-count 5 :poll-interval-ms 500}
            queue store registry))

(worker/start-pool! pool)
(worker/stop-pool! pool)

;; config.edn
:boundary/job-queue {:backend :redis :redis-url #env REDIS_URL}
:boundary/job-store {:backend :redis :redis-url #env REDIS_URL}
:boundary/job-worker {:queue-name :default
                      :worker-count 5
                      :queue   #ig/ref :boundary/job-queue
                      :store   #ig/ref :boundary/job-store
                      :registry #ig/ref :boundary/job-registry}

;; Jobs run in tenant schema context automatically
(job/create-job {:job-type   :sync-inventory
                 :args       {:product-id sku}
                 :tenant-id  "acme-corp"}
                (random-uuid))