Method: Redborder::KafkaNotifier.create_producer_thread

Defined in:
lib/kafka_notifier.rb

.create_producer_thread ⇒ Object 



52
53
54
55
56
57
58
59
 
# File 'lib/kafka_notifier.rb', line 52

def self.create_producer_thread
  Thread.new do
    loop do
      messages = message_queue.pop_all # Get the max number of msgs or wait
      @@producer.send_messages messages unless messages.empty?
    end
  end
end