CHANGES.markdown | 644 | 0 | 0 | | | 3.34 KB | f0855d78ec4f27bc8eb307e65c2267abf4deef5bc48ccdbd08aafc6692080fcb |
VERSION.yml | 644 | 0 | 0 | | | 35 Bytes | 8bd3ef916df6dd0e6b33172b534e267eedc7ea4c44188ba5f0e267918c0831da |
README.markdown | 644 | 0 | 0 | | | 17.3 KB | 783a2571c78bef6938c37f462cf567e31beb67f88cd5c67d348c2d85fd0f0d97 |
TODO.markdown | 644 | 0 | 0 | | | 1.23 KB | 6c9bc56807bf057c6899f6ed71ccc9fff92c862066ad68b326d8687551d06adb |
lib/workling.rb | 644 | 0 | 0 | | | 4.77 KB | 914a2397916a9994c6a2708b9e6425c3a1b8bfee41cdf6988e4e0b9ea323b861 |
lib/rude_q/client.rb | 644 | 0 | 0 | | | 299 Bytes | 3c6e6b5254ff9fcc31ae4bda9a30de15a8d20803528feee78cd54f57b555cb25 |
lib/workling/remote.rb | 644 | 0 | 0 | | | 1.53 KB | 3257a18b11e17383ac17773f2215a27867d67df5644e14882bd12a9ea5b95388 |
lib/workling/rudeq.rb | 644 | 0 | 0 | | | 122 Bytes | 5ede3c1a14cdbc5cc523fe5d9bd2fca27af6173cd4571531a6501ddb58f062ff |
lib/workling/remote/runners/rudeq_runner.rb | 644 | 0 | 0 | | | 614 Bytes | 0b95939ff1c3632f8218662501fd94aabc3aff39f7c4bcda5d451a2b9e809b10 |
lib/workling/remote/runners/not_remote_runner.rb | 644 | 0 | 0 | | | 775 Bytes | 370a15098fa5fabc0f1470fb3a18a51b2704beb702bf64e641e91d203ad8c068 |
lib/workling/remote/runners/backgroundjob_runner.rb | 644 | 0 | 0 | | | 1.21 KB | 2e7ab5f572a16c6ce88a331533067eb51fed9a543c6e88cbfb760e26d1c0c0e5 |
lib/workling/remote/runners/base.rb | 644 | 0 | 0 | | | 1.31 KB | 9f088f15c0d9b46ab379874146fd9ca258c5a2a917efe1baba06e9cf014e1e93 |
lib/workling/remote/runners/starling_runner.rb | 644 | 0 | 0 | | | 249 Bytes | f61c80277f4542a755fe464b1d03f5eaf310b06a3cc9fd452a9a1c0d2261e9cf |
lib/workling/remote/runners/client_runner.rb | 644 | 0 | 0 | | | 1.84 KB | 17c7af7cbd22d8dae61acb85cb082a035e5bb969871cfd7215e102e95504d86c |
lib/workling/remote/runners/spawn_runner.rb | 644 | 0 | 0 | | | 1.28 KB | eed6c7fe3fa3ba9a4804a7c47bee78d76ec80742a7ebf018eadfa24daf2d5f61 |
lib/workling/remote/invokers/base.rb | 644 | 0 | 0 | | | 4.02 KB | 6da87f9f98115a53e0901b2cd4145e14204825f658a9451aa0143f5acc6f42bc |
lib/workling/remote/invokers/basic_poller.rb | 644 | 0 | 0 | | | 874 Bytes | 0221a4db245f0ab0c120bc7ed70ff237afed3b646ac044a58acb8166df99f48f |
lib/workling/remote/invokers/eventmachine_subscriber.rb | 644 | 0 | 0 | | | 971 Bytes | 98ed166b19f5c589efb5785ec84ef42fb5c93cb3e96c6e31b61a6cf3e23d5f22 |
lib/workling/remote/invokers/threaded_poller.rb | 644 | 0 | 0 | | | 5.12 KB | d927ee5a7b19a841de2417fbdf47d9969d2328380f6bf72e04e402538d958c22 |
lib/workling/rudeq/client.rb | 644 | 0 | 0 | | | 313 Bytes | a0ef191d6f1927ca9732e1c0d72364319218954123cb41e28362a071a56b51f7 |
lib/workling/rudeq/poller.rb | 644 | 0 | 0 | | | 3.65 KB | 08cd19d6f8b2102838fa3f5972b655bd7c97b95de896c05bcf7adcd1865111b4 |
lib/workling/routing/base.rb | 644 | 0 | 0 | | | 296 Bytes | 4c0394ef330fd3fd331a0762296470f90a214950f28f15e4fd50923cdfda32e4 |
lib/workling/routing/class_and_method_routing.rb | 644 | 0 | 0 | | | 1.52 KB | e6aa9fc1e1bbf9a574d34b5e04c53a7220b007ba10ddcfe612846f46110552e7 |
lib/workling/base.rb | 644 | 0 | 0 | | | 2.29 KB | beeb4e78e72c52d7a7051748d11de5a378ba73e9197c7f82523fb314164e4d90 |
lib/workling/discovery.rb | 644 | 0 | 0 | | | 358 Bytes | f59f25f9f95e547807e0dc57f1453fab0d006828c915ce8826a9cb7ce017d6df |
lib/workling/clients/memcache_queue_client.rb | 644 | 0 | 0 | | | 2.71 KB | 65c0449248993ac8421abdb6fe176fa061cba0a911c45101a0804bfb61caaa4c |
lib/workling/clients/base.rb | 644 | 0 | 0 | | | 1.58 KB | c596ccd4500c9a0be47bf841fb30286cb498f7178590400e29ccfacdfc747e0f |
lib/workling/clients/amqp_client.rb | 644 | 0 | 0 | | | 1.91 KB | 5e2fe036e620c2b739754dc0428586cce9c8d56da991ff79c08883b73d220956 |
lib/workling/return/store/iterator.rb | 644 | 0 | 0 | | | 394 Bytes | c435f00645c6988a80c89a357594bc33269c2a2e97360375844f0f8a2a4414ab |
lib/workling/return/store/starling_return_store.rb | 644 | 0 | 0 | | | 804 Bytes | cd23089155a5ebc253d001c0cb3b4d459ed998f55d5e32f8488d38b5ee94e686 |
lib/workling/return/store/base.rb | 644 | 0 | 0 | | | 1.15 KB | 272ec6e9fc3785071f3295dc6916d8e4af4c2f9c3a7036531ea014234bedb77c |
lib/workling/return/store/memory_return_store.rb | 644 | 0 | 0 | | | 502 Bytes | 71289bc2426adea2821cdd4f6b68b90740b8ddd3849b1c83121d69c7dcbb72d6 |
lib/workling/return/store/rudeq_return_store.rb | 644 | 0 | 0 | | | 487 Bytes | 50a2d52e6924e97909f93fb76b9057c875a9f19a986fb45389906f7cd99c733c |
test/invoker_eventmachine_subscription_test.rb | 644 | 0 | 0 | | | 1007 Bytes | 9d264ba913b0d31a72bf3c793d15a52a797d43919deb767516524dfb139702ca |
test/discovery_test.rb | 644 | 0 | 0 | | | 559 Bytes | 220648edbababd9e3da72255c9ad4f54002bd9b716cc76e9d22bd017a4f14925 |
test/spawn_runner_test.rb | 644 | 0 | 0 | | | 365 Bytes | 3e95a1cf7051f5458a5d70be02e2dfcca1d27b3de9048a6b27841f63efc9f4cb |
test/starling_runner_test.rb | 644 | 0 | 0 | | | 281 Bytes | 20d9d0a8c965af2718640acf84ead257b45e182a1a933acf53921fc8bbe128d0 |
test/not_remote_runner_test.rb | 644 | 0 | 0 | | | 413 Bytes | f313bfb87c71b1674dbc4ff38ff111427acd1e5851f0fb8281567c611b743437 |
test/starling_return_store_test.rb | 644 | 0 | 0 | | | 1.1 KB | e32fd7d0f10de4057c738e90aabcc9516e7d2e65dec425f2c4509b0fd44830e9 |
test/rudeq_client_test.rb | 644 | 0 | 0 | | | 888 Bytes | d3db6049947fac117910d4735de54b9a4b9395ba0d476527e2ff480ed7837da0 |
test/mocks/logger.rb | 644 | 0 | 0 | | | 87 Bytes | 8334a370a6e53c5fab943bed53c47de4ae68e4278cf37a44fce7a278df2ba4bc |
test/mocks/spawn.rb | 644 | 0 | 0 | | | 51 Bytes | 4908a1b600dbfaaadb719d41cf7ce2f72afbf867356dcbe33e2d275d643617f8 |
test/mocks/client.rb | 644 | 0 | 0 | | | 178 Bytes | 7f9fa1bd29537b7d69d07399d6139a156888109f4a90eb7fcd433f5b85d4d416 |
test/mocks/rude_queue.rb | 644 | 0 | 0 | | | 216 Bytes | 267a898962ec9e5478f72fcac4dcc1be651504079e42455ee5e16d3b0b46dcdd |
test/runners/thread_runner.rb | 644 | 0 | 0 | | | 489 Bytes | bbf395ee481b528cd3cc199e912c30c61898f106cd91651554360b2f347dbf60 |
test/clients/memory_queue_client.rb | 644 | 0 | 0 | | | 842 Bytes | f30ae1d84ca68a69a696acbbfb4b514dcfcc6a68b98e9ce953cdcd78f786ae4f |
test/invoker_basic_poller_test.rb | 644 | 0 | 0 | | | 1.04 KB | 2d0b86c15e0939acbb3f9eaeb9b9158bf947650b832596e132036a775c209b8d |
test/rudeq_poller_test.rb | 644 | 0 | 0 | | | 479 Bytes | 6e4fb55a93c8e8d2b62810d6e82bf43ce572b996bdc573afe2316e86149e58a8 |
test/remote_runner_test.rb | 644 | 0 | 0 | | | 2.49 KB | f2de66f2f9e4e8a15e20a28be3848afb7a4971255612c0ef716ddaf1c148e27e |
test/test_helper.rb | 644 | 0 | 0 | | | 1.64 KB | 7d0d808128f4c4e6e688470cf066a7c1e4444a3c60bef96698abfb3fc616f3dc |
test/workers/analytics/invites.rb | 644 | 0 | 0 | | | 145 Bytes | a96ffe561747fa35eedb196fa166001004b91ed3863f7ee4228c4cf135136ef6 |
test/workers/util.rb | 644 | 0 | 0 | | | 397 Bytes | 4b1ce8ea34f643bf5058f6737759b7806026a894889376d1e1d800913e3f92f2 |
test/memcachequeue_client_test.rb | 644 | 0 | 0 | | | 1.67 KB | 400f0aff1bb89fba4c53b230d22480657aaa658a107f0ac3309eb936e7166e13 |
test/rescue_test.rb | 644 | 0 | 0 | | | 661 Bytes | 6fed83a787bffdf324e58767538c369710af928a783cff4860036e303bd1a75f |
test/class_and_method_routing_test.rb | 644 | 0 | 0 | | | 872 Bytes | 2cd1f7d2b9edbbf9574b5edfe5a2147f042f3f75b183802020e892ba40a6279a |
test/rudeq_return_store_test.rb | 644 | 0 | 0 | | | 469 Bytes | e23f62c369b05e5f517502eb2777deda57740d0563328f107654a1789aa48d1d |
test/invoker_threaded_poller_test.rb | 644 | 0 | 0 | | | 1.24 KB | c2cea43a8a6a897bbc5736ff39c96dbd39fd81e4a8539cdebdd5b0e2b23b1af6 |
test/return_store_test.rb | 644 | 0 | 0 | | | 1.01 KB | a85b1953823b16f581e09c75472caf7531740a387557936a1c21571f23b9def2 |
test/memory_return_store_test.rb | 644 | 0 | 0 | | | 1.06 KB | f45139bbe0fd24afde7d5f317745fe74e0f0203a8d1b1dc3afe7a2e38d5835c8 |
test/rudeq_runner_test.rb | 644 | 0 | 0 | | | 652 Bytes | 698beed45ad73cad453e6ac93eaf16e7ea7108fe220f9839a98273d68d7a0b98 |