Caused by: clojure.lang.ArityException: Wrong number of args (1) passed to: Heartbeat/fn--9444

heartbeat.clj

(ns keypr.core.heartbeat
  (:gen-class)
  (:require [clojure.pprint :refer [pprint]]
            [com.stuartsierra.component :as component]
            [immutant.scheduling :refer [schedule]]
            [keypr.core.event :refer [publish!]]))

(defn trigger-component-heartbeat
  [out-queue options]
  (let [{version :version} options
        payload {:status "running" :version version}]
    (publish! out-queue
              [:component-heartbeat-triggered payload]
              :content-type "application/json"
              :system options)))

(defrecord Heartbeat [out-queue-group options]
  component/Lifecycle
  (start [this]
    (println ";; Starting Heartbeat")
    (pprint out-queue-group)
    (pprint options)
    (let [{version :version} options
          out-queue (first (filter #(= first :heartbeat) out-queue-group))
          job (partial trigger-component-heartbeat out-queue options)]
      (schedule job :every :minute)
      (assoc this :running)))
  (stop [this]
    nil))

(defn heartbeat-ctor
  [options]
  (map->Heartbeat {:options options}))

stack trace

Exception in thread "main" clojure.lang.ExceptionInfo: Error in component :heartbeat in system com.stuartsierra.component.SystemMap calling #'com.stuartsierra.component/start {:r
eason :com.stuartsierra.component/component-function-threw-exception, :function #'com.stuartsierra.component/start, :system-key :heartbeat, :component #keypr.core.heartbeat.Heart
beat{:out-queue-group [[:event #<AutorecoveringChannel com.rabbitmq.client.impl.recovery.AutorecoveringChannel@f79a760>] [:exception #<AutorecoveringChannel com.rabbitmq.client.i
mpl.recovery.AutorecoveringChannel@50fe837a>] [:command #<AutorecoveringChannel com.rabbitmq.client.impl.recovery.AutorecoveringChannel@1623134f>] [:heartbeat #<AutorecoveringCha
nnel com.rabbitmq.client.impl.recovery.AutorecoveringChannel@4264b240>]], :options {:broker-options {:host "localhost", :port 5672, :username "guest", :password "guest", :vhost "
/"}, :events {:component-heartbeat-triggered "0040.0000", :lock-heartbeat-prepared "0500.3000", :tablet-heartbeat-prepared "0500.3100", :heartbeat-projection-deleted "0500.4000",
 :heartbeat-type-flushed "0500.4010"}, :ns-main #<Namespace keypr.thumper.consumer>, :database-options {:classname "org.postgresql.Driver", :subprotocol "postgresql", :subname "/
/localhost:5432/thumper", :user "hero", :password "secret"}, :handlers {"process" keypr.thumper.processor, "aggregate" keypr.thumper.aggregator, "persist" keypr.thumper.persister
}, :component-code "0310", :commands {:save-lock-heartbeat "0500.3000", :save-tablet-heartbeat "0500.3100", :delete-heartbeat-projection "0500.4000", :flush-heartbeat-type "0500.
4010"}, :command-line-args ("process"), :exceptions {:lock-heartbeat-preparation-exception "0500.3000", :tablet-heartbeat-preparation-exception "0500.3100", :heartbeat-type-flush
-exception "0500.4000", :heartbeat-projection-deletion-exception "0500.4010"}, :version "1.0.19", :routing-keys ["*.0500.*"], :queues [[:event "events"] [:exception "exceptions"]
 [:command "commands"] [:heartbeat "heartbeats"]]}}, :system #<SystemMap>}, compiling:(/private/var/folders/dl/2lvnf0mx23vbph1vs4b1m6c40000gn/T/form-init6710942540886051001.clj:1
:124)                                                                                                                                                                            
        at clojure.lang.Compiler.load(Compiler.java:7142)
        at clojure.lang.Compiler.loadFile(Compiler.java:7086)
        at clojure.main$load_script.invoke(main.clj:274)
        at clojure.main$init_opt.invoke(main.clj:279)
        at clojure.main$initialize.invoke(main.clj:307)
        at clojure.main$null_opt.invoke(main.clj:342)
        at clojure.main$main.doInvoke(main.clj:420)
        at clojure.lang.RestFn.invoke(RestFn.java:421)
        at clojure.lang.Var.invoke(Var.java:383)
        at clojure.lang.AFn.applyToHelper(AFn.java:156)
        at clojure.lang.Var.applyTo(Var.java:700)
        at clojure.main.main(main.java:37)
Caused by: clojure.lang.ExceptionInfo: Error in component :heartbeat in system com.stuartsierra.component.SystemMap calling #'com.stuartsierra.component/start {:reason :com.stuar
tsierra.component/component-function-threw-exception, :function #'com.stuartsierra.component/start, :system-key :heartbeat, :component #keypr.core.heartbeat.Heartbeat{:out-queue-
group [[:event #<AutorecoveringChannel com.rabbitmq.client.impl.recovery.AutorecoveringChannel@f79a760>] [:exception #<AutorecoveringChannel com.rabbitmq.client.impl.recovery.Aut
orecoveringChannel@50fe837a>] [:command #<AutorecoveringChannel com.rabbitmq.client.impl.recovery.AutorecoveringChannel@1623134f>] [:heartbeat #<AutorecoveringChannel com.rabbitm
q.client.impl.recovery.AutorecoveringChannel@4264b240>]], :options {:broker-options {:host "localhost", :port 5672, :username "guest", :password "guest", :vhost "/"}, :events {:c
omponent-heartbeat-triggered "0040.0000", :lock-heartbeat-prepared "0500.3000", :tablet-heartbeat-prepared "0500.3100", :heartbeat-projection-deleted "0500.4000", :heartbeat-type
-flushed "0500.4010"}, :ns-main #<Namespace keypr.thumper.consumer>, :database-options {:classname "org.postgresql.Driver", :subprotocol "postgresql", :subname "//localhost:5432/
thumper", :user "hero", :password "secret"}, :handlers {"process" keypr.thumper.processor, "aggregate" keypr.thumper.aggregator, "persist" keypr.thumper.persister}, :component-co
de "0310", :commands {:save-lock-heartbeat "0500.3000", :save-tablet-heartbeat "0500.3100", :delete-heartbeat-projection "0500.4000", :flush-heartbeat-type "0500.4010"}, :command
-line-args ("process"), :exceptions {:lock-heartbeat-preparation-exception "0500.3000", :tablet-heartbeat-preparation-exception "0500.3100", :heartbeat-type-flush-exception "0500
.4000", :heartbeat-projection-deletion-exception "0500.4010"}, :version "1.0.19", :routing-keys ["*.0500.*"], :queues [[:event "events"] [:exception "exceptions"] [:command "comm
ands"] [:heartbeat "heartbeats"]]}}, :system #<SystemMap>}                                                                                                                       
        at clojure.core$ex_info.invoke(core.clj:4403)
        at com.stuartsierra.component$try_action.invoke(component.clj:119)
        at com.stuartsierra.component$update_system$fn__257.invoke(component.clj:136)
        at clojure.core.protocols$fn__6089.invoke(protocols.clj:127)
        at clojure.core.protocols$fn__6057$G__6052__6066.invoke(protocols.clj:19)
        at clojure.core.protocols$seq_reduce.invoke(protocols.clj:31)
        at clojure.core.protocols$fn__6080.invoke(protocols.clj:48)
        at clojure.core.protocols$fn__6031$G__6026__6044.invoke(protocols.clj:13)
        at clojure.core$reduce.invoke(core.clj:6289)
        at com.stuartsierra.component$update_system.doInvoke(component.clj:140)
        at clojure.lang.RestFn.invoke(RestFn.java:445)
        at com.stuartsierra.component$start_system.invoke(component.clj:162)
        at com.stuartsierra.component$start_system.invoke(component.clj:160)
        at com.stuartsierra.component.SystemMap.start(component.clj:177)
        at keypr.thumper.consumer$_main.doInvoke(consumer.clj:129)
        at clojure.lang.RestFn.invoke(RestFn.java:408)
        at clojure.lang.Var.invoke(Var.java:379)
        at user$eval5.invoke(form-init6710942540886051001.clj:1)
        at clojure.lang.Compiler.eval(Compiler.java:6703)
        at clojure.lang.Compiler.eval(Compiler.java:6693)
        at clojure.lang.Compiler.load(Compiler.java:7130)
        ... 11 more
Caused by: clojure.lang.ArityException: Wrong number of args (1) passed to: Heartbeat/fn--9446
        at clojure.lang.AFn.throwArity(AFn.java:429)
        at clojure.lang.AFn.invoke(AFn.java:32)
        at clojure.core$filter$fn__4264.invoke(core.clj:2601)
        at clojure.lang.LazySeq.sval(LazySeq.java:40)
        at clojure.lang.LazySeq.seq(LazySeq.java:49)
        at clojure.lang.LazySeq.first(LazySeq.java:71)
        at clojure.lang.RT.first(RT.java:577)
        at clojure.core$first.invoke(core.clj:55)
        at keypr.core.heartbeat.Heartbeat.start(heartbeat.clj:24)
        at com.stuartsierra.component$fn__206$G__202__208.invoke(component.clj:4)
        at com.stuartsierra.component$fn__206$G__201__211.invoke(component.clj:4)
        at clojure.lang.Var.invoke(Var.java:379)
        at clojure.lang.AFn.applyToHelper(AFn.java:154)
        at clojure.lang.Var.applyTo(Var.java:700)
        at clojure.core$apply.invoke(core.clj:626)
        at com.stuartsierra.component$try_action.invoke(component.clj:116)
        ... 30 more