Method: Kafka::AsyncProducer::Timer#run

Defined in:
lib/kafka/async_producer.rb

#run ⇒ Object 



189
190
191
192
193
194
195
196
197
 
# File 'lib/kafka/async_producer.rb', line 189

def run
  # Permanently sleep if the timer interval is zero.
  Thread.stop if @interval.zero?

  loop do
    sleep(@interval)
    @queue << [:deliver_messages, nil]
  end
end