Skip to content

Commit

Permalink
linting fix
Browse files Browse the repository at this point in the history
  • Loading branch information
prateek.khatri committed Apr 21, 2022
1 parent 98c823f commit 867a69c
Showing 1 changed file with 22 additions and 22 deletions.
44 changes: 22 additions & 22 deletions test/ziggurat/messaging/connection_test.clj
View file
Original file line number Diff line number Diff line change
Expand Up @@ -37,9 +37,9 @@
stream-routes {:default {:handler-fn (constantly :channel-1)
:channel-1 (constantly :success)}}]
(with-redefs [create-rmq-connection (fn [cf provided-config]
(when (some? (:executor provided-config))
(reset! executor-present? true))
(orig-rmq-connect cf provided-config))
(when (some? (:executor provided-config))
(reset! executor-present? true))
(orig-rmq-connect cf provided-config))
config/ziggurat-config (constantly (assoc ziggurat-config
:jobs {:instant {:worker-count 4}}
:retry {:enabled true}
Expand All @@ -60,9 +60,9 @@
stream-routes {:default {:handler-fn (constantly :channel-1)
:channel-1 (constantly :success)}}]
(with-redefs [create-rmq-connection (fn [cf provided-config]
(reset! rmq-connect-called? true)
(reset! thread-count (.getCorePoolSize (:executor provided-config)))
(orig-rmq-connect cf provided-config))
(reset! rmq-connect-called? true)
(reset! thread-count (.getCorePoolSize (:executor provided-config)))
(orig-rmq-connect cf provided-config))
config/ziggurat-config (constantly (assoc ziggurat-config
:jobs {:instant {:worker-count 4}}
:retry {:enabled true}
Expand All @@ -82,10 +82,10 @@
ziggurat-config (config/ziggurat-config)
stream-routes {:default {:handler-fn (constantly :success)}}]
(with-redefs [create-rmq-connection (fn [cf provided-config]
(.getCorePoolSize (:executor provided-config))
(reset! rmq-connect-called? true)
(reset! thread-count (.getCorePoolSize (:executor provided-config)))
(orig-rmq-connect cf provided-config))
(.getCorePoolSize (:executor provided-config))
(reset! rmq-connect-called? true)
(reset! thread-count (.getCorePoolSize (:executor provided-config)))
(orig-rmq-connect cf provided-config))
config/ziggurat-config (constantly (assoc ziggurat-config
:jobs {:instant {:worker-count 4}}
:retry {:enabled true}
Expand All @@ -104,8 +104,8 @@
ziggurat-config (config/ziggurat-config)
stream-routes {:default {:handler-fn (constantly :success)}}]
(with-redefs [create-rmq-connection (fn [cf provided-config]
(reset! rmq-connect-called? true)
(orig-rmq-connect cf provided-config))
(reset! rmq-connect-called? true)
(orig-rmq-connect cf provided-config))
config/ziggurat-config (constantly (assoc ziggurat-config
:retry {:enabled true}
:tracer {:enabled false}))]
Expand All @@ -121,8 +121,8 @@
ziggurat-config (config/ziggurat-config)
stream-routes {:default {:handler-fn (constantly :success)}}]
(with-redefs [create-rmq-connection (fn [cf provided-config]
(reset! rmq-connect-called? true)
(orig-rmq-connect cf provided-config))
(reset! rmq-connect-called? true)
(orig-rmq-connect cf provided-config))
config/ziggurat-config (constantly (-> ziggurat-config
(assoc :retry {:enabled false})
(dissoc :tracer)))]
Expand All @@ -138,8 +138,8 @@
ziggurat-config (config/ziggurat-config)
stream-routes {:default {:handler-fn (constantly :success)}}]
(with-redefs [create-rmq-connection (fn [cf provided-config]
(reset! rmq-connect-called? true)
(orig-rmq-connect cf provided-config))
(reset! rmq-connect-called? true)
(orig-rmq-connect cf provided-config))
config/ziggurat-config (constantly (-> ziggurat-config
(assoc :retry {:enabled false})
(dissoc :tracer)))]
Expand All @@ -158,8 +158,8 @@
:default-1 {:handler-fn (constantly :channel-3)
:channel-3 (constantly :success)}}]
(with-redefs [create-rmq-connection (fn [cf provided-config]
(reset! rmq-connect-called? true)
(orig-rmq-connect cf provided-config))
(reset! rmq-connect-called? true)
(orig-rmq-connect cf provided-config))
config/ziggurat-config (constantly (assoc ziggurat-config
:retry {:enabled false}
:tracer {:enabled false}))]
Expand All @@ -174,8 +174,8 @@
orig-rmq-connect create-rmq-connection
ziggurat-config (config/ziggurat-config)]
(with-redefs [create-rmq-connection (fn [cf provided-config]
(reset! thread-count (.getCorePoolSize (:executor provided-config)))
(orig-rmq-connect cf provided-config))
(reset! thread-count (.getCorePoolSize (:executor provided-config)))
(orig-rmq-connect cf provided-config))
config/ziggurat-config (constantly (assoc ziggurat-config
:jobs {:instant {:worker-count 4}}
:retry {:enabled true}
Expand All @@ -190,8 +190,8 @@
orig-rmq-connect create-rmq-connection
ziggurat-config (config/ziggurat-config)]
(with-redefs [create-rmq-connection (fn [cf provided-config]
(reset! thread-count (.getCorePoolSize (:executor provided-config)))
(orig-rmq-connect cf provided-config))
(reset! thread-count (.getCorePoolSize (:executor provided-config)))
(orig-rmq-connect cf provided-config))
config/ziggurat-config (constantly (assoc ziggurat-config
:jobs {:instant {:worker-count 4}}
:retry {:enabled true}
Expand Down

0 comments on commit 867a69c

Please sign in to comment.