magnet.pubsub.core
PubSubClientcljprotocol
Abstraction for MQTT + AMQP clients publish/subscribe operations
Abstraction for MQTT + AMQP clients publish/subscribe operations
publish!clj
(publish! this destination payload opts)Publish a message with payload as payload, and optional opts
as message meta-data. Uses destination to decide how to route
the message to subscribers. Depending on the protocol
implementation this can be a topic name (MQTT), or a map
specifying an exchange and message routing key (AMQP).
Publish a message with `payload` as payload, and optional `opts` as message meta-data. Uses `destination` to decide how to route the message to subscribers. Depending on the protocol implementation this can be a topic name (MQTT), or a map specifying an exchange and message routing key (AMQP).
subscribe!clj
(subscribe! this topic-or-queue opts callback)Subscribe to receive messages from topic-or-queue.
opts is a map with transport-specific options such as QoS
levels, content type, etc. callback function is called
everytime a message is received. callback is expected to
receive three arguments:
- the topic or queue name
- a map with meta-data about the message
- the message payload (as a byte array)
Returns a subscription tag that is needed for unsubscribing, or nil if there was a problem with the subscription.
Subscribe to receive messages from `topic-or-queue`. `opts` is a map with transport-specific options such as QoS levels, content type, etc. `callback` function is called everytime a message is received. `callback` is expected to receive three arguments: * the topic or queue name * a map with meta-data about the message * the message payload (as a byte array) Returns a subscription tag that is needed for unsubscribing, or nil if there was a problem with the subscription.
unsubscribe!clj
(unsubscribe! this tag)Unsubscribe to receive messages from the topic or queue
associated with tag
Unsubscribe to receive messages from the topic or queue associated with `tag`
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close