class Nsq::Producer
- Nsq::Producer
- Nsq::ClientBase
- Reference
- Object
Defined in:
nsq/producer.crConstructors
Instance Method Summary
-
#deferred_write(delay, *raw_messages : Array(String) | String)
Arg 'delay' in seconds
- #deferred_write_to_topic(topic, delay, *raw_messages : Array(String) | String)
- #topic : String
- #write(*raw_messages : Array(String) | String)
- #write_to_topic(topic, *raw_messages : Array(String) | String)
Instance methods inherited from class Nsq::ClientBase
channel_depth(topic = nil, channel = nil)
channel_depth,
channel_empty(topic = nil, channel = nil)
channel_empty,
connected?
connected?,
connections
connections,
stats(topic = nil, channel = nil)
stats,
terminate
terminate,
topic
topic,
topic_delete(topic = nil, channel = nil)
topic_delete,
topic_msgcount(topic = nil)
topic_msgcount
Instance methods inherited from module Nsq::AttributeLogger
debug(msg)
debug,
error(msg)
error,
fatal(msg)
fatal,
info(msg)
info,
warn(msg)
warn
Class methods inherited from module Nsq::AttributeLogger
included(klass)
included
Constructor Detail
def self.new(opts = new(Hash(Symbol, Array(String) | String | Int32 | Channel(Message | Symbol))))
#