com.timezynk.useful.nsq — com.timezynk/useful 1.19.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)

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.