Table of Contents - nsq-ruby-maglev--1.5.0 Documentation
Pages
- LICENSE
-
README
- nsq-ruby
- Quick start
- Publish messages
- Consume messages
- Producer
- Initialization
#write
#write_to_topic
#connected?
#terminate
- Consumer
- Initialization
#pop
#pop_without_blocking
#size
#terminate
- Message
body
attempts
timestamp
#finish
#touch
#requeue(timeout = 0)
- Logging
- Requirements
- Supports
- Does not support
- Testing
- Is this production ready?
- Authors
- MIT License
Classes and Modules
- Nsq
- Nsq::AttributeLogger
- Nsq::ClientBase
- Nsq::Connection
- Nsq::Consumer
- Nsq::Discovery
- Nsq::DiscoveryException
- Nsq::Error
- Nsq::Frame
- Nsq::Message
- Nsq::Producer
- Nsq::Response
- Nsq::Version
Methods
- ::included — Nsq::AttributeLogger
- ::logger — Nsq
- ::logger= — Nsq
- ::new — Nsq::Connection
- ::new — Nsq::Consumer
- ::new — Nsq::Discovery
- ::new — Nsq::Frame
- ::new — Nsq::Message
- ::new — Nsq::Producer
- #add_connection — Nsq::ClientBase
- #add_connection — Nsq::Consumer
- #close — Nsq::Connection
- #close_connection — Nsq::Connection
- #cls — Nsq::Connection
- #connected? — Nsq::ClientBase
- #connected? — Nsq::Connection
- #connection_for_write — Nsq::Producer
- #connections_changed — Nsq::ClientBase
- #connections_changed — Nsq::Consumer
- #decrement_in_flight — Nsq::Connection
- #die — Nsq::Connection
- #discover_repeatedly — Nsq::ClientBase
- #drop_all_connections — Nsq::ClientBase
- #drop_and_add_connections — Nsq::ClientBase
- #drop_connection — Nsq::ClientBase
- #fin — Nsq::Connection
- #finish — Nsq::Message
- #frame_class_for_type — Nsq::Connection
- #gather_nsqds_from_all_lookupds — Nsq::Discovery
- #get_nsqds — Nsq::Discovery
- #handle_response — Nsq::Connection
- #identify — Nsq::Connection
- #max_in_flight_per_connection — Nsq::Consumer
- #monitor_connection — Nsq::Connection
- #mpub — Nsq::Connection
- #nop — Nsq::Connection
- #nsqds — Nsq::Discovery
- #nsqds_for_topic — Nsq::Discovery
- #nsqds_from_lookupd — Nsq::ClientBase
- #open_connection — Nsq::Connection
- #pop — Nsq::Consumer
- #pop_without_blocking — Nsq::Consumer
- #prefix — Nsq::AttributeLogger
- #pub — Nsq::Connection
- #rdy — Nsq::Connection
- #re_up_ready — Nsq::Connection
- #read_loop — Nsq::Connection
- #receive_frame — Nsq::Connection
- #reconnect — Nsq::Connection
- #redistribute_ready — Nsq::Consumer
- #req — Nsq::Connection
- #requeue — Nsq::Message
- #server_needs_rdy_re_ups? — Nsq::Connection
- #size — Nsq::Consumer
- #snooze — Nsq::Connection
- #start_monitoring_connection — Nsq::Connection
- #start_read_loop — Nsq::Connection
- #start_write_loop — Nsq::Connection
- #stop_monitoring_connection — Nsq::Connection
- #stop_read_loop — Nsq::Connection
- #stop_write_loop — Nsq::Connection
- #sub — Nsq::Connection
- #terminate — Nsq::ClientBase
- #timestamp — Nsq::Message
- #touch — Nsq::Connection
- #touch — Nsq::Message
- #with_retries — Nsq::Connection
- #write — Nsq::Connection
- #write — Nsq::Producer
- #write_loop — Nsq::Connection
- #write_to_socket — Nsq::Connection
- #write_to_topic — Nsq::Producer