Commit Graph

3813 Commits

Author SHA1 Message Date
Gary Tully 184761a119 tidy up redispatch logic a little more, resolve: AMQ-2128, deliver acks on dispose in auto_ack mode. also get some closure on: MQ-2075
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@745953 13f79535-47bb-0310-9956-ffa450edef68
2009-02-19 18:15:59 +00:00
Bosanac Dejan f53e392766 Upgrading Camel https://issues.apache.org/activemq/browse/AMQ-2124
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@745895 13f79535-47bb-0310-9956-ffa450edef68
2009-02-19 15:14:51 +00:00
Bosanac Dejan 76d9fccb2d additional fix for https://issues.apache.org/activemq/browse/AMQ-2085
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@745833 13f79535-47bb-0310-9956-ffa450edef68
2009-02-19 12:09:21 +00:00
Bosanac Dejan 8b0bb3373a additional fix for https://issues.apache.org/activemq/browse/AMQ-2104 and https://issues.apache.org/activemq/browse/AMQ-1509
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@745558 13f79535-47bb-0310-9956-ffa450edef68
2009-02-18 16:24:56 +00:00
Gary Tully 9e3e5ad4cc re AMQ-2076, see if a little more time will help
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@745490 13f79535-47bb-0310-9956-ffa450edef68
2009-02-18 12:15:58 +00:00
Gary Tully 7f5e6667f4 partial fix for AMQ-2075
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@745480 13f79535-47bb-0310-9956-ffa450edef68
2009-02-18 11:43:29 +00:00
Gary Tully 9216c18c73 little refactor of recovery dispatch as now only used for browser dispatch
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@745456 13f79535-47bb-0310-9956-ffa450edef68
2009-02-18 09:44:31 +00:00
Bosanac Dejan 9ad6c089fa fix for https://issues.apache.org/activemq/browse/AMQ-2120
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@745031 13f79535-47bb-0310-9956-ffa450edef68
2009-02-17 12:56:24 +00:00
Gary Tully e48ff70d4b resolve AMQ-2111, only the network subscription that causes the initial subscription needs to be tracked as this is the one that will be propagated via an advisory to the rest of the network. The existing update was making a mod to a possibly inflight advisory message
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@744983 13f79535-47bb-0310-9956-ffa450edef68
2009-02-17 12:04:57 +00:00
Gary Tully 9f8777d3a0 resolve AMQ-2121, shared lock needs to be less contentious
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@744975 13f79535-47bb-0310-9956-ffa450edef68
2009-02-17 11:57:23 +00:00
Gary Tully b4aa979d90 fix intermittent failure when sync close beats async ack
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@744972 13f79535-47bb-0310-9956-ffa450edef68
2009-02-17 11:55:53 +00:00
Bosanac Dejan b0eb9731c0 two consumers test for zero prefetch
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@744947 13f79535-47bb-0310-9956-ffa450edef68
2009-02-16 15:54:04 +00:00
Bosanac Dejan 32d6841a13 A few more failover transport uri test combinations
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@744870 13f79535-47bb-0310-9956-ffa450edef68
2009-02-16 09:50:51 +00:00
Bosanac Dejan 049b43cd17 refactored failover uri test to support testing multiple values
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@744112 13f79535-47bb-0310-9956-ffa450edef68
2009-02-13 13:48:51 +00:00
Bosanac Dejan 479acad417 fix for https://issues.apache.org/activemq/browse/AMQ-2096
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@744082 13f79535-47bb-0310-9956-ffa450edef68
2009-02-13 11:29:01 +00:00
Bosanac Dejan 34b125e18f changing names of excluded kaha tests
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@744042 13f79535-47bb-0310-9956-ffa450edef68
2009-02-13 09:05:10 +00:00
Hiram R. Chirino e16a63815f The wireFormat option needs to get removed otherwise you'll get an error saying that it's unrecognized
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@743870 13f79535-47bb-0310-9956-ffa450edef68
2009-02-12 20:29:31 +00:00
Bosanac Dejan a18a55f75c excluding kaha tests as they are failing occasionally
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@743743 13f79535-47bb-0310-9956-ffa450edef68
2009-02-12 13:58:32 +00:00
Bosanac Dejan 610d5272ec additional fix for https://issues.apache.org/activemq/browse/AMQ-2103; some tests were failing because of this change
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@743741 13f79535-47bb-0310-9956-ffa450edef68
2009-02-12 13:57:22 +00:00
Bosanac Dejan b2148c5e7a fix for https://issues.apache.org/activemq/browse/AMQ-2104
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@743320 13f79535-47bb-0310-9956-ffa450edef68
2009-02-11 13:07:04 +00:00
Robert Davies 69e5f769b2 Fix for https://issues.apache.org/activemq/browse/AMQ-2103
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@743258 13f79535-47bb-0310-9956-ffa450edef68
2009-02-11 07:34:26 +00:00
Gary Tully 9a60743876 test for AMQ-2100
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@743027 13f79535-47bb-0310-9956-ffa450edef68
2009-02-10 17:38:28 +00:00
Gary Tully cfb4234cee fix up org.apache.activemq.network.MulticastNetworkTest
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@742941 13f79535-47bb-0310-9956-ffa450edef68
2009-02-10 11:51:43 +00:00
Bosanac Dejan aed1b5c67c fix for https://issues.apache.org/activemq/browse/AMQ-2101
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@742930 13f79535-47bb-0310-9956-ffa450edef68
2009-02-10 10:45:44 +00:00
Bosanac Dejan 60d6c36ff2 additional fix for https://issues.apache.org/activemq/browse/AMQ-2088
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@742888 13f79535-47bb-0310-9956-ffa450edef68
2009-02-10 08:37:12 +00:00
Robert Davies 586ea12d1e Fix for https://issues.apache.org/activemq/browse/AMQ-2100
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@742876 13f79535-47bb-0310-9956-ffa450edef68
2009-02-10 08:07:16 +00:00
Gary Tully 504bcf0596 demote log error or async exception to warn, with sendFailIfNoSpace, logs gets spammed with expected error messages
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@742603 13f79535-47bb-0310-9956-ffa450edef68
2009-02-09 16:33:50 +00:00
Bosanac Dejan 15065b71c7 fix for https://issues.apache.org/activemq/browse/AMQ-2088
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@742458 13f79535-47bb-0310-9956-ffa450edef68
2009-02-09 12:49:42 +00:00
Gary Tully 4dda0d8353 resolve npe if no mbeans found
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@742443 13f79535-47bb-0310-9956-ffa450edef68
2009-02-09 12:27:07 +00:00
Gary Tully 657e6fa1dd add extra assert to consumer advisory test
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@742377 13f79535-47bb-0310-9956-ffa450edef68
2009-02-09 10:26:19 +00:00
Hiram R. Chirino b7c2b678bb Added a new TempKahaDBStore which is an optimized KahaDB based message for temporary messages.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@741769 13f79535-47bb-0310-9956-ffa450edef68
2009-02-06 22:49:01 +00:00
Hiram R. Chirino f73b622a60 Change the way journal records are validated on recovery to be consistent. We now use a checksum to provide better consistency.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@741741 13f79535-47bb-0310-9956-ffa450edef68
2009-02-06 21:35:39 +00:00
Hiram R. Chirino d761e80ae4 - added some handy generic visitors to the BTreeVisitor class.
- Updated the recovery process so it now rollsback changes applied to the index which did not get synced to the journal.



git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@741659 13f79535-47bb-0310-9956-ffa450edef68
2009-02-06 18:19:31 +00:00
Gary Tully ca80106573 resolve unit test break, check for tx need to be overridden to take care of shared case
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@741646 13f79535-47bb-0310-9956-ffa450edef68
2009-02-06 17:28:13 +00:00
Hiram R. Chirino 789ea7cab9 Making the removeDataFile a little smarter to avoid removing data files that are still being worked on
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@741600 13f79535-47bb-0310-9956-ffa450edef68
2009-02-06 15:54:19 +00:00
Hiram R. Chirino 51e82d59e7 better synchronization of the metadata.lastUpdate var
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@741597 13f79535-47bb-0310-9956-ffa450edef68
2009-02-06 15:42:22 +00:00
Gary Tully deea2d11a8 expose relevant index attributes for configuration from kahadb
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@741528 13f79535-47bb-0310-9956-ffa450edef68
2009-02-06 10:59:47 +00:00
Hiram R. Chirino d89a302041 Fixed StoreQueueCursorKahaDBNoDuplicateTest
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@741334 13f79535-47bb-0310-9956-ffa450edef68
2009-02-05 22:46:01 +00:00
Hiram R. Chirino 273933378b Opps miss a couple of commits with that last change.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@741329 13f79535-47bb-0310-9956-ffa450edef68
2009-02-05 22:42:42 +00:00
Hiram R. Chirino 180b0ec4ab - Implemented the setBatch API call in KahaDBStore.
- fixed bug: When a async thread was used for writing in KahaDBStore you could run in a Memory leak due to an unbound enqueue buffer type problem.



git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@741327 13f79535-47bb-0310-9956-ffa450edef68
2009-02-05 22:41:01 +00:00
Gary Tully 63709a9a88 test for setBatch with KahaDB AMQ-2020
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@741325 13f79535-47bb-0310-9956-ffa450edef68
2009-02-05 22:38:31 +00:00
Gary Tully f0af62f64d add a little more info to flush
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@741293 13f79535-47bb-0310-9956-ffa450edef68
2009-02-05 21:15:13 +00:00
Hiram R. Chirino 8262ef7903 Changed the cleanup algorithm used in the KahaDB.. It should now be much faster.
Fixed bug in the BTreeNode.visit() which was making us load most of the pages instead of letting us filter down to just a few.



git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@741212 13f79535-47bb-0310-9956-ffa450edef68
2009-02-05 18:07:57 +00:00
Hiram R. Chirino c0594251e2 Bettter property names.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@741169 13f79535-47bb-0310-9956-ffa450edef68
2009-02-05 16:33:23 +00:00
Hiram R. Chirino 19c4316a1c Added the ability to customize thw write batch size in the PageFile.
Added some diagnostic logging to see when store updates take too long and why.



git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@741137 13f79535-47bb-0310-9956-ffa450edef68
2009-02-05 15:29:48 +00:00
Gary Tully 3c543a0cd0 pass asyncWrite flag to page file
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@741136 13f79535-47bb-0310-9956-ffa450edef68
2009-02-05 15:29:00 +00:00
Bosanac Dejan 690b7bcbd1 a couple of Stomp improvements
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@741109 13f79535-47bb-0310-9956-ffa450edef68
2009-02-05 14:33:59 +00:00
Gary Tully c22cd6563b update simple enqueue rate verifier for kaha store
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@741096 13f79535-47bb-0310-9956-ffa450edef68
2009-02-05 13:07:32 +00:00
Gary Tully 9bb46820b2 store specific tests for setBatch http://issues.apache.org/activemq/browse/AMQ-2020
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@741061 13f79535-47bb-0310-9956-ffa450edef68
2009-02-05 10:06:39 +00:00
Gary Tully 37c2a955a2 move setBatch to MessageStore interface to keep cursors store agnostic - http://issues.apache.org/activemq/browse/AMQ-2020 - some store specific tests to follow
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@740765 13f79535-47bb-0310-9956-ffa450edef68
2009-02-04 15:19:56 +00:00