Sha256: c804605305137863530021816d9b424160f79d740d8253a7b0ae03e72fa9b55f
Contents?: true
Size: 1.88 KB
Versions: 6
Compression:
Stored size: 1.88 KB
Contents
require 'rubygems' require 'bundler' begin Bundler.setup(:default, :development) rescue Bundler::BundlerError => e $stderr.puts e.message $stderr.puts "Run `bundle install` to install missing gems" exit e.status_code end require 'simplecov' SimpleCov.start do add_filter "/test/" add_group 'SidekiqCron', 'lib/' end require 'coveralls' Coveralls.wear! require "minitest/autorun" require 'shoulda-context' require "rack/test" require "mocha/setup" ENV['RACK_ENV'] = 'test' #SIDEKIQ Require - need to have sidekiq running! require 'sidekiq' require 'sidekiq/util' require 'sidekiq/web' Sidekiq.logger.level = Logger::ERROR require 'sidekiq/redis_connection' redis_url = ENV['REDIS_URL'] || 'redis://0.0.0.0:6379' REDIS = Sidekiq::RedisConnection.create(:url => redis_url, :namespace => 'testy') Sidekiq.configure_client do |config| config.redis = { :url => redis_url, :namespace => 'testy' } end $LOAD_PATH.unshift(File.join(File.dirname(__FILE__), '..', 'lib')) $LOAD_PATH.unshift(File.dirname(__FILE__)) require 'sidekiq-cron' require 'sidekiq/cron/web' require 'pp' class CronTestClass include Sidekiq::Worker sidekiq_options retry: true def perform args = {} puts "super croned job #{args}" end end class CronTestClassWithQueue include Sidekiq::Worker sidekiq_options queue: :super, retry: false, backtrace: true def perform args = {} puts "super croned job #{args}" end end module ActiveJob class Base def self.queue_name_prefix @queue_name_prefix end def self.queue_name_prefix=(queue_name_prefix) @queue_name_prefix = queue_name_prefix end def self.set(options) @queue = options['queue'] self end def self.perform_later(*args) { "job_class" => self.class.name, "queue_name" => @queue, "args" => [*args], } end end end class ActiveJobCronTestClass < ActiveJob::Base end
Version data entries
6 entries across 6 versions & 1 rubygems