6668fe0a3b573de3f33f7fb0e5eb22959e2423e9 Ben Mabey ben@benmabey.com http://github.com/bmabey/rosetta_queue/commit/7658238c3def69cb621c8fed8fbd3d76ce33c1a4 7658238c3def69cb621c8fed8fbd3d76ce33c1a4 2009-12-21T06:04:48-08:00 2009-12-21T06:04:48-08:00 Releasing 0.5.0. f8d2b7d788d5cc4cd08003f18f069dca92b73f50 Ben Mabey ben@benmabey.com 84a65c678e798d755eb1f780f132c68f9e0e1711 0390fad584f75a4a351982b15d45c56957f23b01 Ben Mabey ben@benmabey.com http://github.com/bmabey/rosetta_queue/commit/6668fe0a3b573de3f33f7fb0e5eb22959e2423e9 6668fe0a3b573de3f33f7fb0e5eb22959e2423e9 2009-12-21T06:03:33-08:00 2009-12-21T06:03:33-08:00 Merge branch 'cwyckoff/0.5' 312888987d9b420af3d78e29abcada3b4a044cfe Ben Mabey ben@benmabey.com 45c942c3e7f654cf2fe206e153c5da43f92e15db Chris Wyckoff cbwyckoff@gmail.com http://github.com/bmabey/rosetta_queue/commit/0390fad584f75a4a351982b15d45c56957f23b01 0390fad584f75a4a351982b15d45c56957f23b01 2009-12-20T22:14:40-08:00 2009-12-20T22:14:40-08:00 Consumer.receive was returning adapter instance; now it returns message received. 98fa6095d9c1b43e38364c2e72053accdc58969d Chris Wyckoff cbwyckoff@gmail.com 45c942c3e7f654cf2fe206e153c5da43f92e15db Ben Mabey ben@benmabey.com http://github.com/bmabey/rosetta_queue/commit/84a65c678e798d755eb1f780f132c68f9e0e1711 84a65c678e798d755eb1f780f132c68f9e0e1711 2009-12-20T22:10:39-08:00 2009-12-20T22:10:39-08:00 updating history in prep for 0.5 release 972cf47b777e2350c94942a3fced4494ea4e5dc3 Ben Mabey ben@benmabey.com f3f19ea8481e8c2b9df041afecee5a0a9d8ddea6 Chris Wyckoff cbwyckoff@gmail.com http://github.com/bmabey/rosetta_queue/commit/45c942c3e7f654cf2fe206e153c5da43f92e15db 45c942c3e7f654cf2fe206e153c5da43f92e15db 2009-12-20T21:50:37-08:00 2009-12-20T21:50:37-08:00 removed dependency on message_handler when calling [Adapter]#disconnect * cached 'destination' on stomp adapter * cached 'exchange_strategy' on amqp adapters 66eb18d85b7f7e6e624f81e50a26acdf6acf1000 Chris Wyckoff cbwyckoff@gmail.com c74d8c99512bb4a9140fb14eb0ddb62fe34ea593 Chris Wyckoff cbwyckoff@gmail.com http://github.com/bmabey/rosetta_queue/commit/f3f19ea8481e8c2b9df041afecee5a0a9d8ddea6 f3f19ea8481e8c2b9df041afecee5a0a9d8ddea6 2009-12-20T21:50:16-08:00 2009-12-20T21:50:16-08:00 moved AmqpEventedAdapter and AmqpSynchAdapter classes to amqp.rb with parent Amqp class d05e6d270c66d8754660c2c827dcb3b02769bc3a Chris Wyckoff cbwyckoff@gmail.com 949dfca29841ab6f8efbc56938d859af370690c1 Chris Wyckoff cbwyckoff@gmail.com http://github.com/bmabey/rosetta_queue/commit/c74d8c99512bb4a9140fb14eb0ddb62fe34ea593 c74d8c99512bb4a9140fb14eb0ddb62fe34ea593 2009-12-20T21:44:08-08:00 2009-12-20T21:44:08-08:00 removed unneccesary shared behavior specs e014bbbda2b6efca12e93a058f2415ba97d288f8 Chris Wyckoff cbwyckoff@gmail.com f3fcfe50556896b483f82fdd3c488315a2b50d71 Chris Wyckoff cbwyckoff@gmail.com http://github.com/bmabey/rosetta_queue/commit/949dfca29841ab6f8efbc56938d859af370690c1 949dfca29841ab6f8efbc56938d859af370690c1 2009-12-20T21:42:26-08:00 2009-12-20T21:42:26-08:00 removed unneccesary StompProxy class fa1f750096b26648f9bc825fa59c3e62bf6338e6 Chris Wyckoff cbwyckoff@gmail.com 24fa7b6bee115b6c71bacca1d6390d66a7362949 Chris Wyckoff cbwyckoff@gmail.com http://github.com/bmabey/rosetta_queue/commit/f3fcfe50556896b483f82fdd3c488315a2b50d71 f3fcfe50556896b483f82fdd3c488315a2b50d71 2009-12-20T21:40:51-08:00 2009-12-20T21:40:51-08:00 moved base.rb methods into Consumer class and removed the Base class 378ef90d409b30dd44011c446be7f1787a844c02 Chris Wyckoff cbwyckoff@gmail.com a79fcb0a03a0fe9c97d25a2bdddc9cd43e4db866 Chris Wyckoff and Ben Mabey developers@leadmediapartners.com http://github.com/bmabey/rosetta_queue/commit/24fa7b6bee115b6c71bacca1d6390d66a7362949 24fa7b6bee115b6c71bacca1d6390d66a7362949 2009-12-11T14:29:35-08:00 2009-12-11T14:29:35-08:00 removing dead spec d278e3bc972edc2a3f826aaec10f21cf9e3f0d0a Chris Wyckoff cbwyckoff@gmail.com e5d3a2e4640ef3d6805fe7ac44d2019cb18b9d5c Chris Wyckoff and Ben Mabey developers@leadmediapartners.com http://github.com/bmabey/rosetta_queue/commit/a79fcb0a03a0fe9c97d25a2bdddc9cd43e4db866 a79fcb0a03a0fe9c97d25a2bdddc9cd43e4db866 2009-12-11T14:25:11-08:00 2009-12-11T14:19:30-08:00 Remove Adapter::instance in favor of Adapter::open. ( see previous commits for reasoning ) c0ee8cd037b8eae30aedb3c858e9c50e5ef803f8 Chris Wyckoff cbwyckoff@gmail.com 4f16b7ee040135549a9d2f242f1568bb583b44fb Larry Karnowski and Rob Sanheim pair@thinkrelevance.com http://github.com/bmabey/rosetta_queue/commit/e5d3a2e4640ef3d6805fe7ac44d2019cb18b9d5c e5d3a2e4640ef3d6805fe7ac44d2019cb18b9d5c 2009-12-07T07:59:01-08:00 2009-12-07T07:59:01-08:00 Update History for proposed 0.5.0 release to push back to Ben Mabey for review fce8c9507eca80a2fe69b54ae12e2185aab0e009 Larry Karnowski and Rob Sanheim pair@thinkrelevance.com 26413e3b6ce8cf133811d6ec315edcdfbcf5d386 Larry Karnowski and Rob Sanheim pair@thinkrelevance.com http://github.com/bmabey/rosetta_queue/commit/4f16b7ee040135549a9d2f242f1568bb583b44fb 4f16b7ee040135549a9d2f242f1568bb583b44fb 2009-12-07T07:53:52-08:00 2009-12-07T07:51:07-08:00 Further adapter refinements: - Make Amqp adapter interface match all other adapters, even though Amqp really _does_ require the message handler passed in (unlike all the other adapters). - TODO: There is a definite need to move some state around in order to clean up this inconsistency. - few more specs around open, demonstrating it cleans up even if the block raises - add/clean up RDoc 9e4dcc1b50a24f4abbcabf0605a9a0d80ec0b4b5 Larry Karnowski and Rob Sanheim pair@thinkrelevance.com 7a145a61c1f70be37e07240f400ebb6857c4c270 Larry Karnowski larry.karnowski@gmail.com http://github.com/bmabey/rosetta_queue/commit/26413e3b6ce8cf133811d6ec315edcdfbcf5d386 26413e3b6ce8cf133811d6ec315edcdfbcf5d386 2009-12-03T13:54:19-08:00 2009-12-03T13:54:19-08:00 Fixed "Adapter.open" for Stomp; note it's still broken for AQMP. - Leaky abstraction on Stomp & AQMP adapters was requiring a message handler to be passed to "#disconnect" to unsubscribe, even if it hadn't been subscribed. - Changed the Stomp adapter to take the message handler as an optional parameter to "#disconnect" and only unsubscribe if passed one. e9972766168881a17e50c4148b53bb1b7dbe58ee Larry Karnowski larry.karnowski@gmail.com 992de55e9b5998c18b5b63030bdc54d1a50ee4e7 Larry Karnowski larry.karnowski@gmail.com http://github.com/bmabey/rosetta_queue/commit/7a145a61c1f70be37e07240f400ebb6857c4c270 7a145a61c1f70be37e07240f400ebb6857c4c270 2009-12-03T13:54:07-08:00 2009-12-03T13:54:07-08:00 Ensure we disconnect on exception. b07077c7338c6abcbc24246a16f868c81a9347fe Larry Karnowski larry.karnowski@gmail.com a46ccb8942f29311b02310ffa18acf6d09ef056f Larry Karnowski larry.karnowski@gmail.com http://github.com/bmabey/rosetta_queue/commit/992de55e9b5998c18b5b63030bdc54d1a50ee4e7 992de55e9b5998c18b5b63030bdc54d1a50ee4e7 2009-12-03T12:28:45-08:00 2009-12-03T12:28:45-08:00 Fixed a socket leak (at least for Stomp, but probably others too). - "Adapter.instance" creates a NEW instance each time it is called, but the expectation is that it would return a lazily-cached, singleton instance. - When you call Producer.publish, it called "instance", evidently assuming it would get a singleton instance because it doesn't "disconnect" the adapter. - Each time a Stomp adapter is created, it opens a socket to the queue. - So, each time you publish a message via Stomp, it would leak a socket. - (This might happen on other adapters, too. Not sure.) - So we created a new "Adapter.open" method that disconnects the adapter after the given block is evaluated. - We could have fixed "instance" to be a true singleton, but it's unclear what code is relying on the accidentally-thread-safe current implementation. We felt it safer to create a new method. 827c835c811b7cb3201eba367eac093f750af3c9 Larry Karnowski larry.karnowski@gmail.com e626789b4f298de5a8af05a1ce7a0ac4259c4158 Larry Karnowski larry.karnowski@gmail.com http://github.com/bmabey/rosetta_queue/commit/a46ccb8942f29311b02310ffa18acf6d09ef056f a46ccb8942f29311b02310ffa18acf6d09ef056f 2009-12-03T12:20:35-08:00 2009-12-03T12:20:35-08:00 Fixed some misspellings. c48f5fae2019c1a9be3d7d616be80dfaf28ecad4 Larry Karnowski larry.karnowski@gmail.com 4b67c0ccb0d48312b9647159dfa01402885710ec Larry Karnowski and Rob Sanheim pair@thinkrelevance.com http://github.com/bmabey/rosetta_queue/commit/e626789b4f298de5a8af05a1ce7a0ac4259c4158 e626789b4f298de5a8af05a1ce7a0ac4259c4158 2009-12-03T10:06:14-08:00 2009-12-03T10:06:14-08:00 Found a socket leak in the Stomp adapter because of Adapter.instance... - Basically, Adapter.instance doesn't do what you think it does. - Instead of being a singleton that returns a cached instance, it creates a new one every time. - The Stomp client expects a singleton, so it doesn't close the socket when publishing. - We are going to follow up with a fix for this in the next commit. 906552e661b700954d184787426fe87c44c5f4c4 Larry Karnowski and Rob Sanheim pair@thinkrelevance.com 50950ddbd1f8ecf2c546dfc0c99a418933e3d001 Larry Karnowski and Rob Sanheim pair@thinkrelevance.com http://github.com/bmabey/rosetta_queue/commit/4b67c0ccb0d48312b9647159dfa01402885710ec 4b67c0ccb0d48312b9647159dfa01402885710ec 2009-12-03T08:46:13-08:00 2009-12-03T08:45:03-08:00 Allow specifying a key when adding handlers to a consumer.... This allows you to add multiple instances of the same handler class. Otherwise the last one wins in the @consumers hash due to having the same key name. Add spec for base consumer contract of #add 32c228d46ae778e508add548fa4e86e66b6fa1f9 Larry Karnowski and Rob Sanheim pair@thinkrelevance.com 313fff17b8c5d4c3012e51d574565f207e0aa184 c28b773a40ab932cb8a77b066c794b24d1ed29b0 Larry Karnowski and Rob Sanheim pair@thinkrelevance.com http://github.com/bmabey/rosetta_queue/commit/50950ddbd1f8ecf2c546dfc0c99a418933e3d001 50950ddbd1f8ecf2c546dfc0c99a418933e3d001 2009-12-03T08:30:59-08:00 2009-12-03T08:30:59-08:00 Merge branch 'master' into relevance-master: - Added eventmachine require to Evented consumer manager - 2 specs broken otherwise without this require -- maybe load order issues that were sys dependent? dce782a863818c1d3dbcef8b9c279e29754ad213 Larry Karnowski and Rob Sanheim pair@thinkrelevance.com 7459677e5378a3accf6e4d72c8b9ed254843c555 Larry Karnowski and Rob Sanheim pair@thinkrelevance.com http://github.com/bmabey/rosetta_queue/commit/313fff17b8c5d4c3012e51d574565f207e0aa184 313fff17b8c5d4c3012e51d574565f207e0aa184 2009-12-03T08:25:25-08:00 2009-12-03T08:25:25-08:00 Need to require 'amqp' here; otherwise specs fail ab683365d3cd2bcf43783b58ede7f1c4c3d9e847 Larry Karnowski and Rob Sanheim pair@thinkrelevance.com 944c9778bcecbbeeb5040fd5b476b535d91fdcca Ben Mabey ben@benmabey.com http://github.com/bmabey/rosetta_queue/commit/c28b773a40ab932cb8a77b066c794b24d1ed29b0 c28b773a40ab932cb8a77b066c794b24d1ed29b0 2009-09-28T15:20:13-07:00 2009-09-28T15:20:13-07:00 Version bump to 0.4.0 fb77341978f69ed85db1954a20e7a7dae053b94b Ben Mabey ben@benmabey.com 896758e1eaac8e7731c544e566d8c02ad510cea9 Ben Mabey ben@benmabey.com http://github.com/bmabey/rosetta_queue/commit/944c9778bcecbbeeb5040fd5b476b535d91fdcca 944c9778bcecbbeeb5040fd5b476b535d91fdcca 2009-09-28T15:18:05-07:00 2009-09-28T15:12:33-07:00 Allowing registration of custom exception handling. See lib/rosetta_queue/exception_handler.rb for more info. This removes some default exception handling that was present in RQ prior to this for publishing and consuming. Since every app tends to want to handle exceptions differently for messaging but are generally pretty consistent across consumers/publishers this feature gives the needed flexibility and helps reduce duplication within apps. a051043428b040e765f9728c9d15734bc689c0f2 Ben Mabey ben@benmabey.com bd25e0e64098e110eadfc9e7f5d863e3b4f140cf Ben Mabey ben@benmabey.com http://github.com/bmabey/rosetta_queue/commit/896758e1eaac8e7731c544e566d8c02ad510cea9 896758e1eaac8e7731c544e566d8c02ad510cea9 2009-09-25T11:43:55-07:00 2009-09-25T11:43:55-07:00 Version bump to 0.4.0 00db9225f0c356d14060640d8c6ba8c3068d43d1 Ben Mabey ben@benmabey.com f726dc75478c8112ce7def1afe5213600765db7a Ben Mabey ben@benmabey.com http://github.com/bmabey/rosetta_queue/commit/bd25e0e64098e110eadfc9e7f5d863e3b4f140cf bd25e0e64098e110eadfc9e7f5d863e3b4f140cf 2009-09-25T10:15:02-07:00 2009-09-25T10:15:02-07:00 Version bump to 0.3.0 e45b166a9eac5c36061ef3e70ade0d5a808e8bf5 Ben Mabey ben@benmabey.com 8a958e6df4c3ccfdd77913478c87bb81e36cd1c8 Ben Mabey ben@benmabey.com http://github.com/bmabey/rosetta_queue/commit/f726dc75478c8112ce7def1afe5213600765db7a f726dc75478c8112ce7def1afe5213600765db7a 2009-09-24T13:23:13-07:00 2009-09-24T13:23:13-07:00 removing reader for dest hash on Destinations ce04e28b4747fa3a3fac3633d180e75deb02b0dc Ben Mabey ben@benmabey.com 2a99cbe04c6148d790f6606cd9d648685fe0d53b Ben Mabey ben@benmabey.com http://github.com/bmabey/rosetta_queue/commit/8a958e6df4c3ccfdd77913478c87bb81e36cd1c8 8a958e6df4c3ccfdd77913478c87bb81e36cd1c8 2009-09-23T15:01:02-07:00 2009-09-23T15:01:02-07:00 updating History aa92b9a45ac369a10013833ca23310bef7fe5e11 Ben Mabey ben@benmabey.com 1e9832131bdef842ef98c99ef0181f69f8f20875 Ben Mabey ben@benmabey.com http://github.com/bmabey/rosetta_queue/commit/2a99cbe04c6148d790f6606cd9d648685fe0d53b 2a99cbe04c6148d790f6606cd9d648685fe0d53b 2009-09-23T14:54:08-07:00 2009-09-23T14:54:08-07:00 fixed stomp features and marked the Publish-Subscribe as unreliable Publish-Subscribe works but has been problematic to test within the features. Need to fix it.... 7a23e911c9c3f3075a2fe3702d7644d221a98554 Ben Mabey ben@benmabey.com 7a01bf490ee1e6f69b8c26ad8b12e999dee4fc91 Ben Mabey ben@benmabey.com http://github.com/bmabey/rosetta_queue/commit/1e9832131bdef842ef98c99ef0181f69f8f20875 1e9832131bdef842ef98c99ef0181f69f8f20875 2009-09-23T13:57:32-07:00 2009-09-23T13:57:32-07:00 whitespace begone! addb2fc3b058c9e275fcceffc029807a7d5dee98 Ben Mabey ben@benmabey.com ca5e2276a5b3d849f59fe58479fa349e3d5a03a4 Ben Mabey ben@benmabey.com http://github.com/bmabey/rosetta_queue/commit/7a01bf490ee1e6f69b8c26ad8b12e999dee4fc91 7a01bf490ee1e6f69b8c26ad8b12e999dee4fc91 2009-09-23T13:55:29-07:00 2009-09-23T13:55:29-07:00 retab features and uncomment stomp adapter af8b681d654715c19668a36808780241c27f73e4 Ben Mabey ben@benmabey.com