diff --git a/src/main/clj/clj_camel/core.clj b/src/main/clj/clj_camel/core.clj index b9152a3..46f380d 100644 --- a/src/main/clj/clj_camel/core.clj +++ b/src/main/clj/clj_camel/core.clj @@ -145,12 +145,6 @@ [^ProcessorDefinition processor-definition & [^Expression expr]] (.setBody processor-definition expr)) -(defn set-in-body [^Exchange ex body] - (-> ex .getIn (.setBody body))) - -(defn set-in-header [^Exchange ex k value] - (-> ex .getIn (.setHeader (str k) value))) - (defn simple "Creates simple expression eg. (c/idempotent-consumer (c/simple '${body}') (c/create-memory-idempotent-repository))" @@ -465,6 +459,12 @@ (defn get-in-header [^Exchange ex k] (-> ex (.getIn) (.getHeader (name k)))) +(defn set-in-body [^Exchange ex body] + (-> ex .getIn (.setBody body))) + +(defn set-in-header [^Exchange ex k value] + (-> ex .getIn (.setHeader (name k) value))) + (defn debug-exchange-log [ex] (log/warn "------------------------------------------") (log/warn "From endpoint:" (get-endpoint-uri ex))