module Kinetic::DSL::TimedEvents

Public Instance Methods

timed_event(label, interval, options={}, &block) click to toggle source

Creates a timed event that fired at the set interval. Can be used to broadcast messages to all connected workers.

# File lib/kinetic/dsl/timed_events.rb, line 7
def timed_event(label, interval, options={}, &block)
  timed_events[label] = {interval: interval, options: options, block: block}
end