Module: NSQ

Extended by:
Loggable
Defined in:
lib/nsq/backoff_timer.rb,
lib/nsq.rb,
lib/nsq/util.rb,
lib/nsq/timer.rb,
lib/nsq/reader.rb,
lib/nsq/message.rb,
lib/nsq/loggable.rb,
lib/nsq/publisher.rb,
lib/nsq/connection.rb,
lib/nsq/subscriber.rb,
lib/nsq/queue_subscriber.rb

Overview

Stolen from pynsq library since somebodies thought about this a lot more than me

Defined Under Namespace

Modules: Loggable, Util Classes: BackoffTimer, Connection, Message, Publisher, QueueSubscriber, Reader, Subscriber, Timer

Constant Summary collapse

MAGIC_V2 = 
"  V2"
FRAME_TYPE_RESPONSE = 
0
FRAME_TYPE_ERROR = 
1
FRAME_TYPE_MESSAGE = 
2

Class Method Summary collapse

Methods included from Loggable

default_logger, logger, logger=, rails_logger

Class Method Details

.create_reader(options, &block) ⇒ Object

:nodoc:



21
22
23
24
 
# File 'lib/nsq.rb', line 21

def self.create_reader(options, &block) #:nodoc:
  NSQ.logger.info('NSQ#create_reader has been deprecated, please use NSQ::Reader#new instead')
  Reader.new(options, &block)
end