Contents

require 'clockwork'
require 'observed'
require "observed/clockwork/version"
require "observed/application"

module Observed
  module Clockwork
    extend self

    def register_observed_handler(args)
      Observed.init!
      Observed.configure args
      Observed.load! args[:config_file]
      ::Clockwork.handler do |job|
        Observed.run job
      end
    end

  end
end

Version data entries

2 entries across 2 versions & 2 rubygems

Version	Path
observed-0.1.1	integrations/observed-clockwork/lib/observed/clockwork.rb
observed-clockwork-0.1.0	lib/observed/clockwork.rb