73d9ef10ad602a792d3c86aa4c24c510e9122307 Keith Rarick kr@xph.us http://github.com/kr/async-observer/commit/1c68fc44bf686108eaa789128781ce139a44c4b5 1c68fc44bf686108eaa789128781ce139a44c4b5 2009-10-11T18:31:37-07:00 2009-10-11T18:31:37-07:00 Should have done this long ago. b9de9fdf23771ec52cec59cbed600ceae90196b3 Keith Rarick kr@xph.us 2277b155fb3a44dbbbbaf6e50a1ad27cc0f42acb Kevin Ball kball@causes.com http://github.com/kr/async-observer/commit/73d9ef10ad602a792d3c86aa4c24c510e9122307 73d9ef10ad602a792d3c86aa4c24c510e9122307 2008-07-21T05:41:09-07:00 2008-07-21T05:40:09-07:00 Add rrepr method on Time e2a5421f2022086b2fcf54dda020bbf82b7ce76e Keith Rarick kr@causes.com 96a837ccb1bc94165d285353ae66f23e666e7802 Keith Rarick kr@causes.com http://github.com/kr/async-observer/commit/2277b155fb3a44dbbbbaf6e50a1ad27cc0f42acb 2277b155fb3a44dbbbbaf6e50a1ad27cc0f42acb 2008-07-21T00:16:07-07:00 2008-07-21T00:08:00-07:00 Provide a safety option for non-idempotent jobs. 1fb80c95cbf82b37d22a6620d683cbda6f24cf01 Keith Rarick kr@causes.com 8d84f1c50c6dc92bccfc7f09d84e789dce8555d3 Keith Rarick kr@causes.com http://github.com/kr/async-observer/commit/96a837ccb1bc94165d285353ae66f23e666e7802 96a837ccb1bc94165d285353ae66f23e666e7802 2008-07-21T00:16:07-07:00 2008-07-21T00:13:34-07:00 An extensible way to pass options to the worker. 813c02d9630c82f51b8bce6cc8b58233caf0c6c2 Keith Rarick kr@causes.com fe0eb0e2ea8517f0463b854d0640fa7062204dac Keith Rarick kr@causes.com http://github.com/kr/async-observer/commit/8d84f1c50c6dc92bccfc7f09d84e789dce8555d3 8d84f1c50c6dc92bccfc7f09d84e789dce8555d3 2008-07-14T16:57:58-07:00 2008-07-14T16:56:17-07:00 Be sure to flush the log after jobs. 61003df31a32e376ad57b7372e01d30336facf5d Keith Rarick kr@causes.com 4bc4fa5804ddd73e598f66cfaef7e30955b428ea Keith Rarick kr@causes.com http://github.com/kr/async-observer/commit/fe0eb0e2ea8517f0463b854d0640fa7062204dac fe0eb0e2ea8517f0463b854d0640fa7062204dac 2008-07-01T19:13:01-07:00 2008-07-01T19:13:01-07:00 Whoops, this isn't standard ruby/rails. da29d0019cd92afbce86a21de0f56e585e77c4c1 Keith Rarick kr@causes.com dd939e9c30169f44c0a498b29f0e98aa665ee98d Keith Rarick kr@causes.com http://github.com/kr/async-observer/commit/4bc4fa5804ddd73e598f66cfaef7e30955b428ea 4bc4fa5804ddd73e598f66cfaef7e30955b428ea 2008-06-20T16:44:04-07:00 2008-06-20T14:03:13-07:00 Add a :fanout_pri option to async_each. 03daaee78270a6632b6e046d4f6a3dabc3863d14 Keith Rarick kr@causes.com 97066c85066bac150e5f1b58d6cdd3708ffd1abc Keith Rarick kr@causes.com http://github.com/kr/async-observer/commit/dd939e9c30169f44c0a498b29f0e98aa665ee98d dd939e9c30169f44c0a498b29f0e98aa665ee98d 2008-06-20T14:02:08-07:00 2008-06-20T13:36:33-07:00 Support :direct priority in async_send calls. 5c93f87df2b72e616a76e903c724b156f746078a Keith Rarick kr@causes.com 8b9fdbdd77abdcc92ac37a15c2f64a23011c24d7 Keith Rarick kr@causes.com http://github.com/kr/async-observer/commit/97066c85066bac150e5f1b58d6cdd3708ffd1abc 97066c85066bac150e5f1b58d6cdd3708ffd1abc 2008-06-10T13:31:26-07:00 2008-06-10T13:31:26-07:00 Die properly when we get a TERM signal. b283c1aed251f42cb9fa1a73fe4f859574529526 Keith Rarick kr@causes.com 483404f886263b8fdb8423cb9c01a47b7738efb2 Keith Rarick kr@causes.com http://github.com/kr/async-observer/commit/8b9fdbdd77abdcc92ac37a15c2f64a23011c24d7 8b9fdbdd77abdcc92ac37a15c2f64a23011c24d7 2008-06-03T16:06:26-07:00 2008-06-03T16:06:26-07:00 Avoid generating single-element ranges in edge-case. 6d80bbb8f239cfe4fa1e9366844f6d4688d62aa0 Keith Rarick kr@causes.com 27325cc959ae0bfb7242eba9d96045fc56b8db10 Keith Rarick kr@causes.com http://github.com/kr/async-observer/commit/483404f886263b8fdb8423cb9c01a47b7738efb2 483404f886263b8fdb8423cb9c01a47b7738efb2 2008-06-03T13:00:12-07:00 2008-06-03T13:00:12-07:00 Simpler, more comprehensible source line info. e049ee18f26c4fb007051df2d59caacb78e4ee4a Keith Rarick kr@causes.com 6a6674fcedd68e76f5c690298ba591f836147458 Keith Rarick kr@causes.com http://github.com/kr/async-observer/commit/27325cc959ae0bfb7242eba9d96045fc56b8db10 27325cc959ae0bfb7242eba9d96045fc56b8db10 2008-06-02T22:49:50-07:00 2008-06-02T21:04:01-07:00 Fix async_hook handling, even with inheritance. This reverts the previous "use cattr_accessor" patch, simplifies things a bit, and calls the proper hooks depending on where in the class hierarchy the usual rails hook was called. ceae6315b6c4a193c6eafea0b4e11d47bf17aee4 Keith Rarick kr@causes.com 169b62d3bedcf26663e068986bfff3956e6bb1c5 Keith Rarick kr@causes.com http://github.com/kr/async-observer/commit/6a6674fcedd68e76f5c690298ba591f836147458 6a6674fcedd68e76f5c690298ba591f836147458 2008-06-02T17:45:40-07:00 2008-06-02T17:45:40-07:00 Support a "direct" priority to run jobs synchronously. b8c069428f084349a0ad1b6c774880fa754a8fa5 Keith Rarick kr@causes.com a424e8382726c98b4cd41d6620d2968bb8947e6a Keith Rarick kr@causes.com http://github.com/kr/async-observer/commit/169b62d3bedcf26663e068986bfff3956e6bb1c5 169b62d3bedcf26663e068986bfff3956e6bb1c5 2008-06-02T17:16:14-07:00 2008-06-02T17:16:14-07:00 Quietly do nothing if the record doesn't exist. c45360d3dee7e463033f77e404d612b73a77bdd4 Keith Rarick kr@causes.com b25e6c7b890ac9bc5f041c7cafc836d4112a4519 Keith Rarick kr@causes.com http://github.com/kr/async-observer/commit/a424e8382726c98b4cd41d6620d2968bb8947e6a a424e8382726c98b4cd41d6620d2968bb8947e6a 2008-06-02T16:24:07-07:00 2008-06-02T16:24:07-07:00 Easy way to run a method on every record in a model. 20ea2570249a1fcd6679c9d9cbdc4a1ad79bf4f3 Keith Rarick kr@causes.com 975cd3eea3854fa986eeb3cc7d19b79e3e7364af Keith Rarick kr@causes.com http://github.com/kr/async-observer/commit/b25e6c7b890ac9bc5f041c7cafc836d4112a4519 b25e6c7b890ac9bc5f041c7cafc836d4112a4519 2008-06-02T15:53:22-07:00 2008-06-02T15:53:22-07:00 New feature: Range#async_each. 66c36beab67fb2a31a1f18aa360643d9fc3de1f0 Keith Rarick kr@causes.com dbcdbed8d2576d5d7d2ec710ea3e58189e7e6668 Keith Rarick kr@causes.com http://github.com/kr/async-observer/commit/975cd3eea3854fa986eeb3cc7d19b79e3e7364af 975cd3eea3854fa986eeb3cc7d19b79e3e7364af 2008-06-02T15:43:11-07:00 2008-06-02T15:43:11-07:00 Support async messages to ranges. a33fe131631605c98329ea2ecac2038af2c3a498 Keith Rarick kr@causes.com 5644c1c35c9e882a84719408501859fd99b80988 Keith Rarick kr@causes.com http://github.com/kr/async-observer/commit/dbcdbed8d2576d5d7d2ec710ea3e58189e7e6668 dbcdbed8d2576d5d7d2ec710ea3e58189e7e6668 2008-06-02T15:02:22-07:00 2008-06-02T15:02:22-07:00 Support optional "fuzz" on the priority. d1f4bccd13ecba776f315ab89d93e318db6a3ae8 Keith Rarick kr@causes.com aff37b3b311a3857796b3cd592c1b3e41ebf47ef Dustin dsallings@gmail.com http://github.com/kr/async-observer/commit/5644c1c35c9e882a84719408501859fd99b80988 5644c1c35c9e882a84719408501859fd99b80988 2008-05-31T16:26:57-07:00 2008-04-18T13:54:19-07:00 Revert "Since we're already in the metaclass, use attr_accessor." All of my tests fail with this change. I'm pretty sure cattr_accessor is required. This reverts commit 71f66b477e090200ce8e6d3cf0e1590f6820fddb. b93e5865a5be9731d07bd7232d0b398cefc09ad9 Keith Rarick kr@causes.com a9d2c50cde81ac31c42cdcf5922829049ed0da1b eshansen@gmail.com eshansen@gmail.com http://github.com/kr/async-observer/commit/aff37b3b311a3857796b3cd592c1b3e41ebf47ef aff37b3b311a3857796b3cd592c1b3e41ebf47ef 2008-05-31T16:12:24-07:00 2008-05-30T13:16:50-07:00 Reconnect to the database if necessary. This fixes the "mysql server has gone away" error that occurs on low-traffic systems when mysqld closes an idle connection after 8 hours. 4fb82a5f78e6dc3d8b8331ab81b7b043e73472c7 Keith Rarick kr@causes.com 016290c2c0fb9facc1640657882f10340be03f09 Keith Rarick kr@causes.com http://github.com/kr/async-observer/commit/a9d2c50cde81ac31c42cdcf5922829049ed0da1b a9d2c50cde81ac31c42cdcf5922829049ed0da1b 2008-05-31T15:50:45-07:00 2008-05-27T16:46:14-07:00 Give the user a chance to deal with DEADLINE_SOON. 9a23880bf05dc435a34468bc27172a7021a75cad Keith Rarick kr@causes.com 7765d8f10298dc1de39116b44a930cc54d4550ca Keith Rarick kr@causes.com http://github.com/kr/async-observer/commit/016290c2c0fb9facc1640657882f10340be03f09 016290c2c0fb9facc1640657882f10340be03f09 2008-05-31T15:50:45-07:00 2008-05-21T18:41:23-07:00 Call after_put hook after put, not just async_send. b06260246b6d30fe25ec37899fca0a3dd814531c Keith Rarick kr@causes.com 1a6db8760d7250cb380752c0737ecbeaba73c765 Keith Rarick kr@causes.com http://github.com/kr/async-observer/commit/7765d8f10298dc1de39116b44a930cc54d4550ca 7765d8f10298dc1de39116b44a930cc54d4550ca 2008-05-08T12:04:34-07:00 2008-05-08T12:04:34-07:00 Remove dead code/data. git-svn-id: svn+ssh://rubyforge.org/var/svn/async-observer/async_observer@33 f42208c8-597e-4dc9-a40e-02aa0bb3b44f 2226c689a07a41ccaa831a531c59677a40cd33e8 Keith Rarick kr@causes.com 4d276cf36a9c688c87a250004a5e8a63e876260a Keith Rarick kr@causes.com http://github.com/kr/async-observer/commit/1a6db8760d7250cb380752c0737ecbeaba73c765 1a6db8760d7250cb380752c0737ecbeaba73c765 2008-05-08T11:59:19-07:00 2008-05-08T11:59:19-07:00 Don't bomb out if the app_version is unset. git-svn-id: svn+ssh://rubyforge.org/var/svn/async-observer/async_observer@32 f42208c8-597e-4dc9-a40e-02aa0bb3b44f 2b3a0be8cd8f09b6f69daa61a0fd2a632dc52086 Keith Rarick kr@causes.com f53688a6f239e979dacc604efddceb02c02166b1 Keith Rarick kr@causes.com http://github.com/kr/async-observer/commit/4d276cf36a9c688c87a250004a5e8a63e876260a 4d276cf36a9c688c87a250004a5e8a63e876260a 2008-05-08T11:51:56-07:00 2008-05-08T11:51:56-07:00 Return the job id and server address. git-svn-id: svn+ssh://rubyforge.org/var/svn/async-observer/async_observer@31 f42208c8-597e-4dc9-a40e-02aa0bb3b44f 00d3b0caf1207828f4f0cbcceb7692c95352efd7 Keith Rarick kr@causes.com 0968720392a593f96ca2e8483e3ec6d2600d9fa5 Keith Rarick kr@causes.com http://github.com/kr/async-observer/commit/f53688a6f239e979dacc604efddceb02c02166b1 f53688a6f239e979dacc604efddceb02c02166b1 2008-05-08T11:51:55-07:00 2008-05-08T11:51:55-07:00 Remove code to run jobs in an alternate version. git-svn-id: svn+ssh://rubyforge.org/var/svn/async-observer/async_observer@30 f42208c8-597e-4dc9-a40e-02aa0bb3b44f 7f644e51757c91b338fd6f1257efd2a17efaa7df Keith Rarick kr@causes.com 59cc500c4c08f7ef64bd494dc56a1377e676e7e2 Keith Rarick kr@causes.com http://github.com/kr/async-observer/commit/0968720392a593f96ca2e8483e3ec6d2600d9fa5 0968720392a593f96ca2e8483e3ec6d2600d9fa5 2008-04-25T18:02:15-07:00 2008-04-25T18:02:15-07:00 Provide the worker instance to the job user hook. git-svn-id: svn+ssh://rubyforge.org/var/svn/async-observer/async_observer@29 f42208c8-597e-4dc9-a40e-02aa0bb3b44f e178e736b8dd1e87bcfb5a1ad4d0c00b85335235 Keith Rarick kr@causes.com 7d0e961187e2c61f0159ebd23d3d3e66fdca1670 Keith Rarick kr@causes.com http://github.com/kr/async-observer/commit/59cc500c4c08f7ef64bd494dc56a1377e676e7e2 59cc500c4c08f7ef64bd494dc56a1377e676e7e2 2008-04-25T18:02:14-07:00 2008-04-25T18:02:14-07:00 Return the job id and server address. git-svn-id: svn+ssh://rubyforge.org/var/svn/async-observer/async_observer@28 f42208c8-597e-4dc9-a40e-02aa0bb3b44f 7ee8506f005e327d1f8abc8df295e2f52a0f5490 Keith Rarick kr@causes.com e64c67b0c409f114cac468007e19bca5ff51ffdc Keith Rarick kr@causes.com http://github.com/kr/async-observer/commit/7d0e961187e2c61f0159ebd23d3d3e66fdca1670 7d0e961187e2c61f0159ebd23d3d3e66fdca1670 2008-04-25T18:02:12-07:00 2008-04-25T18:02:12-07:00 Include a hook to run after putting each job. git-svn-id: svn+ssh://rubyforge.org/var/svn/async-observer/async_observer@27 f42208c8-597e-4dc9-a40e-02aa0bb3b44f b75947eea478439d78ec579d8726726109a42a82 Keith Rarick kr@causes.com db24ebd3e0f5bc39230672718b6709bf57a3c112 Keith Rarick kr@causes.com http://github.com/kr/async-observer/commit/e64c67b0c409f114cac468007e19bca5ff51ffdc e64c67b0c409f114cac468007e19bca5ff51ffdc 2008-04-25T18:02:11-07:00 2008-04-25T18:02:11-07:00 Include a hook to run before running jobs. git-svn-id: svn+ssh://rubyforge.org/var/svn/async-observer/async_observer@26 f42208c8-597e-4dc9-a40e-02aa0bb3b44f 6dd031ae4d477578fc00c0e4cd098edc155f36bb Keith Rarick kr@causes.com