Method: Redborder::KafkaNotifier::MessageQueue#initialize

Defined in:
lib/kafka_notifier/message_queue.rb

#initialize(limit = 500, timeout = 1) ⇒ MessageQueue

Returns a new instance of MessageQueue.



19
20
21
22
23
24
25
 
# File 'lib/kafka_notifier/message_queue.rb', line 19

def initialize(limit = 500, timeout = 1)
  @mutex = Mutex.new
  @queue = []
  @limit = limit
  @timeout = timeout
  @recieved = ConditionVariable.new
end