gateway.domains.bus.core — com.tick42.gateway/bus-domain 3.0.20

bus-domain clj/s

(bus-domain)

handle-request clj/s multimethod

join clj/s

(join state source request)

matches-routing? clj/s

(matches-routing? sub-key key)

matches-subscription? clj/s

(matches-subscription? topic routing-key [_ subscription])

checks if given topic and routing key match an existing subscription

matches-target? clj/s

(matches-target? target peer)

matches-topic? clj/s

(matches-topic? {sub-topic :topic sub-pattern :topic-repattern} topic)

checks if sub-topic matches topic

publish clj/s

(publish state source request)

publish* clj/s

(publish* state request publisher)

distributes a message onto all matching subscribers

source-removed clj/s

(source-removed state source _)

Source has disconnected from the system

subscribe clj/s

(subscribe state source request)

subscribe* clj/s

(subscribe* state request subscription-id peer)

subscriptions->messages clj/s

(subscriptions->messages peer)

generates messages that applied on a remote node will join the peer to the bus domain and register its subscriptions

topic->pattern clj/s

(topic->pattern topic)

unsubscribe clj/s

(unsubscribe state source request)

unsubscribe* clj/s

(unsubscribe* state request peer)

wildcard? clj/s

(wildcard? topic)

zip-peer-subscriptions clj/s

(zip-peer-subscriptions peers)

given a collection of peers, returns a [[peer subscription-a] [peer subscription-b]] where subscription-a and subscription-b are the topic subscriptions of the peer