                              (format "Timed out after %d ms when dereferencing the result of step %s"
                                timeout current-step)))
           (msg/publish pl m
-            :encoding :clojure
+            :encoding :none
             :properties {"step" next-step
                          correlation-property (get-correlation-property raw-message)}))))
     f))

  (step
    (fn [m]
      (msg/publish pl (if m (.body m))
        :encoding :clojure
        :ttl ttl
        :properties {"result" true, correlation-property (get-correlation-property m)}))
    :decode? false))

          (throw (IllegalArgumentException.
                   (format "'%s' is not one of the available steps: %s" step (vec step-names)))))
        (msg/publish pl m
          :encoding :none
          :properties {"step" step, correlation-property id})
        (create-delay pl id keep-result?)))
    assoc
