File tree Expand file tree Collapse file tree 2 files changed +3
-3
lines changed
clojure/wheel/src/wheel/infra/cron/job Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change 6
6
(qj/defjob AllocateOrderJob [ctx]
7
7
(job/handle channel/allocate-order ctx))
8
8
9
- (defmethod job /jobtype :allocate-order [_]
9
+ (defmethod job /job-type :allocate-order [_]
10
10
AllocateOrderJob )
Original file line number Diff line number Diff line change 8
8
[wheel.middleware.event :as event]
9
9
[wheel.infra.log :as log]))
10
10
11
- (defmulti jobtype :type )
11
+ (defmulti job-type :type )
12
12
13
13
(defn- identifier [{:keys [channel-id type]}]
14
14
(str channel-id " /" (name type)))
15
15
16
16
(defn- create-job [channel-config cron-job-config]
17
17
(qj/build
18
- (qj/of-type (jobtype cron-job-config))
18
+ (qj/of-type (job-type cron-job-config))
19
19
(qj/using-job-data {:channel-config channel-config
20
20
:cron-job-config cron-job-config})
21
21
(qj/with-identity (qj/key (identifier cron-job-config)))))
You can’t perform that action at this time.
0 commit comments