nsq

A client library for the NSQ messaging platform
Library nsq
Module Nsq . Consumer
module Config : sig ... end
type t
val create : ?mode:[ `Nsqd | `Lookupd ] -> ?config:Config.t -> Address.t list -> Topic.t -> Channel.t -> ( bytes -> [ `Ok | `Requeue ] Lwt.t ) -> t
val run : t -> unit Lwt.t