God , Resque, Resque-schedule, is working,but buggy. Need to combine with LDAP and also implement XML calendar sync.
This commit is contained in:
parent
dbac219c18
commit
7af17f19ac
1
Gemfile
1
Gemfile
|
@ -21,6 +21,7 @@ gem 'radius'
|
||||||
gem 'rake'
|
gem 'rake'
|
||||||
gem 'resque' # background jobs
|
gem 'resque' # background jobs
|
||||||
gem 'resque-scheduler' # job scheduling
|
gem 'resque-scheduler' # job scheduling
|
||||||
|
gem 'resque-restriction'
|
||||||
gem 'ruby-debug19'
|
gem 'ruby-debug19'
|
||||||
gem 'rubyzip'
|
gem 'rubyzip'
|
||||||
gem 'sinatra'
|
gem 'sinatra'
|
||||||
|
|
|
@ -161,6 +161,8 @@ GEM
|
||||||
redis-namespace (~> 1.0.2)
|
redis-namespace (~> 1.0.2)
|
||||||
sinatra (>= 0.9.2)
|
sinatra (>= 0.9.2)
|
||||||
vegas (~> 0.1.2)
|
vegas (~> 0.1.2)
|
||||||
|
resque-restriction (0.3.0)
|
||||||
|
resque (>= 1.7.0)
|
||||||
resque-scheduler (1.9.9)
|
resque-scheduler (1.9.9)
|
||||||
redis (>= 2.0.1)
|
redis (>= 2.0.1)
|
||||||
resque (>= 1.8.0)
|
resque (>= 1.8.0)
|
||||||
|
@ -276,10 +278,7 @@ DEPENDENCIES
|
||||||
rails (>= 3.1.0, < 3.2.0)
|
rails (>= 3.1.0, < 3.2.0)
|
||||||
rake
|
rake
|
||||||
resque
|
resque
|
||||||
<<<<<<< HEAD
|
|
||||||
resque-restriction
|
resque-restriction
|
||||||
=======
|
|
||||||
>>>>>>> starting Resque
|
|
||||||
resque-scheduler
|
resque-scheduler
|
||||||
rspec (~> 2.0)
|
rspec (~> 2.0)
|
||||||
rspec-rails (~> 2.0)
|
rspec-rails (~> 2.0)
|
||||||
|
|
|
@ -1,13 +1,15 @@
|
||||||
# require 'open-uri'
|
# require 'open-uri'
|
||||||
# require 'nokogiri'
|
# require 'nokogiri'
|
||||||
module FetchTime
|
class FetchTime < Resque::Plugins::RestrictionJob
|
||||||
@queue = :my_job_queue
|
restrict :per_300 => 10
|
||||||
|
|
||||||
|
@queue = :low
|
||||||
|
|
||||||
def self.perform()
|
def self.perform()
|
||||||
# sleep 10
|
# sleep 10
|
||||||
# doc = Nokogiri::HTML(open('http://www.timeanddate.com/worldclock/city.html?n=241'))
|
doc = Nokogiri::HTML(open('http://www.timeanddate.com/worldclock/city.html?n=241'))
|
||||||
# CronMail.time_check(doc.at('#ct').children.first.text).deliver
|
CronMail.time_check(doc.at('#ct').children.first.text).deliver
|
||||||
# puts "Mail Sent"
|
puts "Mail Sent"
|
||||||
# true
|
true
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
|
@ -3,7 +3,7 @@ require 'resque_scheduler'
|
||||||
# require 'yaml'
|
# require 'yaml'
|
||||||
|
|
||||||
Resque.redis = 'localhost:6379'
|
Resque.redis = 'localhost:6379'
|
||||||
Resque.redis.namespace = "resque:SchedulerExample"
|
#Resque.redis.namespace = "resque:SchedulerExample"
|
||||||
|
|
||||||
# If you want to be able to dynamically change the schedule,
|
# If you want to be able to dynamically change the schedule,
|
||||||
# uncomment this line. A dynamic schedule can be updated via the
|
# uncomment this line. A dynamic schedule can be updated via the
|
||||||
|
|
|
@ -1,5 +1,17 @@
|
||||||
do_my_job:
|
do_mail_matt:
|
||||||
every: 30s
|
every: 10s
|
||||||
class: FetchTime
|
class: FetchTime
|
||||||
args:
|
args:
|
||||||
description: Runs the perform method in MyJob
|
description: Runs the perform method in FetchTime
|
||||||
|
|
||||||
|
nccu_daily_ldap_sync:
|
||||||
|
cron: 30 * * * * *
|
||||||
|
class: SyncDb
|
||||||
|
args:
|
||||||
|
description: Runs the perform method in SnycDB
|
||||||
|
|
||||||
|
nccu_claender_sync:
|
||||||
|
every: 1m
|
||||||
|
class: NccuCalendar
|
||||||
|
args:
|
||||||
|
description: Runs the perform method in NccuCalendar
|
Reference in New Issue