com.timezynk.useful.nsq — com.timezynk/useful 4.17.0

create-message-handler clj

(create-message-handler f)

Turns function f into a Java object which implements MessageHandler.

create-publish-api clj

(create-publish-api servers config)

Creates a com.sproutsocial.nsq.Publisher object.

create-subscribe-api clj

(create-subscribe-api lookup-server config)

Creates a com.sproutsocial.nsq.Subscriber object.

http-publish clj

(http-publish url topic message)

Publishes on the NSQ bus over HTTP.

• url URL of nsqd
• topic NSQ topic to post to
• message Clojure hash representation of message to post Returns the HTTP response.

publish clj

(publish api topic message)

Asynchronously serializes and publishes message on topic through api. Returns the operation wrapped in a future.

subscribe clj

(subscribe api topic channel f)

Idempotently subscribes f to topic on channel through api. f must take two string arguments: topic and message.