2014-08-12 14:24:19 -04:00
|
|
|
require File.expand_path('../../../load_paths', __FILE__)
|
2014-05-18 05:44:28 -04:00
|
|
|
|
|
|
|
require 'active_job'
|
|
|
|
|
2014-08-16 21:06:30 -04:00
|
|
|
GlobalID.app = 'aj'
|
|
|
|
|
2014-08-13 08:57:23 -04:00
|
|
|
@adapter = ENV['AJADAPTER'] || 'inline'
|
2014-05-21 13:08:59 -04:00
|
|
|
|
2014-08-13 08:57:23 -04:00
|
|
|
def sidekiq?
|
|
|
|
@adapter == 'sidekiq'
|
|
|
|
end
|
|
|
|
|
|
|
|
def rubinius?
|
|
|
|
RUBY_ENGINE == 'rbx'
|
|
|
|
end
|
|
|
|
|
|
|
|
def ruby_193?
|
|
|
|
RUBY_VERSION == '1.9.3' && RUBY_ENGINE != 'java'
|
|
|
|
end
|
|
|
|
|
|
|
|
#Sidekiq don't work with MRI 1.9.3
|
|
|
|
#Travis uses rbx 2.6 which don't support unicode characters in methods.
|
|
|
|
#Remove the check when Travis change to rbx 2.7+
|
|
|
|
exit if sidekiq? && (ruby_193? || rubinius?)
|
|
|
|
|
|
|
|
require "adapters/#{@adapter}"
|
2014-05-20 11:59:50 -04:00
|
|
|
|
2014-08-05 02:05:14 -04:00
|
|
|
require 'active_support/testing/autorun'
|
2014-05-21 09:50:29 -04:00
|
|
|
|
2014-08-05 02:05:14 -04:00
|
|
|
ActiveJob::Base.logger.level = Logger::DEBUG
|
2014-08-17 09:23:24 -04:00
|
|
|
|
|
|
|
module JobBuffer
|
|
|
|
class << self
|
|
|
|
def clear
|
|
|
|
@buffer = []
|
|
|
|
end
|
|
|
|
|
|
|
|
def add(value)
|
|
|
|
@buffer << value
|
|
|
|
end
|
|
|
|
|
|
|
|
def values
|
|
|
|
@buffer
|
|
|
|
end
|
|
|
|
|
|
|
|
def last_value
|
|
|
|
@buffer.last
|
|
|
|
end
|
|
|
|
end
|
|
|
|
end
|