purzelrakete / workling

easily do background work in rails, without commiting to a particular runner. comes with starling, bj and spawn runners.

This URL has Read+Write access

Marshal AMQP message data
rtomayko (author)
Wed Mar 18 07:49:45 -0700 2009
purzelrakete (committer)
Wed Mar 18 11:34:00 -0700 2009
commit  a7b52c7c158ab0f9ccaf963d0aa56266a5e91c00
tree    4637e702101e34457dbfa9232bd94efb9aacc4ec
parent  550799ddffacb7db86f0d7c712cde647ccb6e600
workling / test / test_helper.rb
100644 48 lines (40 sloc) 1.553 kb
raw blame history 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48

plugin_test = File.dirname(__FILE__)
plugin_root = File.join plugin_test, '..'
plugin_lib = File.join plugin_root, 'lib'
 
require 'rubygems'
require 'active_support'
require 'active_record'
require 'test/spec'
require 'mocha'
 
$:.unshift plugin_lib, plugin_test
 
RAILS_ENV = "test"
RAILS_ROOT = File.dirname(__FILE__) + "/.." # fake the rails root directory.
RAILS_DEFAULT_LOGGER = Logger.new(STDOUT)
RAILS_DEFAULT_LOGGER.level = Logger::WARN
 
require "mocks/spawn"
require "mocks/logger"
require "workling"
require "workling/base"
 
Workling.try_load_a_memcache_client
 
require "workling/discovery"
require "workling/routing/class_and_method_routing"
require "workling/remote/invokers/basic_poller"
require "workling/remote/invokers/threaded_poller"
require "workling/remote/invokers/eventmachine_subscriber"
require "workling/remote"
require "workling/remote/runners/not_remote_runner"
require "workling/remote/runners/spawn_runner"
require "workling/remote/runners/starling_runner"
require "workling/remote/runners/client_runner"
require "workling/remote/runners/backgroundjob_runner"
require "workling/return/store/memory_return_store"
require "workling/return/store/starling_return_store"
require "mocks/client"
require "clients/memory_queue_client"
require "runners/thread_runner"
 
# worklings are in here.
Workling.load_path = ["#{ plugin_root }/test/workers"]
Workling::Return::Store.instance = Workling::Return::Store::MemoryReturnStore.new
Workling::Discovery.discover!
 
# make this behave like production code
Workling.raise_exceptions = false