clamq.pipes — clamq/clamq-core 0.4

multi-pipe clj

(multi-pipe {{source :endpoint
              s-connection :connection
              s-pubSub :pubSub
              :or {s-pubSub false}}
               :from
             destinations :to
             failure-fn :on-failure
             transacted :transacted
             limit :limit
             :or {failure-fn helpers/rethrow-on-failure limit 0}})

Pipe clj protocol

close clj

(close self)

open clj

(open self)

router-pipe clj

(router-pipe {{source :endpoint
               s-connection :connection
               s-pubSub :pubSub
               :or {s-pubSub false}}
                :from
              router-fn :route-with
              failure-fn :on-failure
              transacted :transacted
              limit :limit
              :or {failure-fn helpers/rethrow-on-failure limit 0}})

single-pipe clj

(single-pipe
  {{source :endpoint
    s-connection :connection
    s-pubSub :pubSub
    :or {s-pubSub false}}
     :from
   {destination :endpoint
    d-connection :connection
    d-pubSub :pubSub
    :or {d-pubSub false}}
     :to
   filter-fn :filter-by
   failure-fn :on-failure
   transacted :transacted
   limit :limit
   :or {filter-fn identity failure-fn helpers/rethrow-on-failure limit 0}})