Method: Nsq::Consumer#size

Defined in:
lib/nsq/consumer.rb

#size ⇒ Object

returns the number of messages we have locally in the queue



71
72
73
 
# File 'lib/nsq/consumer.rb', line 71

def size
  @messages.size
end