class Nsq::Connection

• Nsq::Connection
• Reference
• Object

Included Modules

• Nsq::AttributeLogger

Defined in:

nsq/connection.cr

Constant Summary

CLOSE_WAIT = "CLOSE_WAIT"

ERROR_INVALID = "E_INVALID"

FRAME_CLASSES = [Response, Error, Message]

RESPONSE_HEARTBEAT = "_heartbeat_"

RESPONSE_OK = "OK"

USER_AGENT = "nsq-crystal/#{Nsq::VERSION}"

Constructors

• .new(opts : Opts)

Instance Method Summary

• #channel_depth(topic : String, channel : String)
• #channel_empty(topic = nil, channel = nil)
• #close

  close the connection and don't try to re-open it

• #connected?
• #dpub(topic, delay_in_ms, message)
• #fin(message_id : String)
• #host : String
• #max_in_flight : Int32
• #max_in_flight=(max_in_flight : Int32)
• #mpub(topic, messages)
• #port : Int32
• #presumed_in_flight : Int32
• #pub(topic, message : String)
• #rdy(count)
• #re_up_ready

  Tell the server we are ready for more messages!

• #req(message_id, timeout)
• #stats(topic = nil, channel = nil)
• #sub(topic, channel)
• #topic_delete(topic = nil)
• #topic_msgcount(topic : String)
• #touch(message_id)

Constructor Detail

Instance Method Detail