Commit Graph

4444 Commits

Author SHA1 Message Date
Timothy A. Bish ba4a9ed841 fix for: https://issues.apache.org/jira/browse/AMQ-3828
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1349527 13f79535-47bb-0310-9956-ffa450edef68
2012-06-12 21:09:37 +00:00
Timothy A. Bish 4bba15a763 fix for: https://issues.apache.org/jira/browse/AMQ-3852
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1349383 13f79535-47bb-0310-9956-ffa450edef68
2012-06-12 14:52:47 +00:00
Timothy A. Bish a307c57e98 Adds a little test to show that messages cross the network bridge that are sent compressed remain compressed.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1349030 13f79535-47bb-0310-9956-ffa450edef68
2012-06-11 21:41:21 +00:00
Timothy A. Bish 4a7f870593 Test can fail on slower machines, give it a bit more time and improve the assert output.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1348983 13f79535-47bb-0310-9956-ffa450edef68
2012-06-11 19:43:52 +00:00
Bosanac Dejan cfd28536b9 https://issues.apache.org/jira/browse/AMQ-3845 - exclude assertion in sync case as ldap connection close time is unpredictable
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1348885 13f79535-47bb-0310-9956-ffa450edef68
2012-06-11 14:58:28 +00:00
Gary Tully c1fbf53b72 https://issues.apache.org/jira/browse/AMQ-3845 - increase the refresh rate in the test for slower machines
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1348880 13f79535-47bb-0310-9956-ffa450edef68
2012-06-11 14:52:17 +00:00
Bosanac Dejan 06949a5074 https://issues.apache.org/jira/browse/AMQ-3845 - handle LDAP restarts in cached ldap authorization map
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1348761 13f79535-47bb-0310-9956-ffa450edef68
2012-06-11 09:24:51 +00:00
Timothy A. Bish 21a0465448 fix build issue with some Generic types.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1348483 13f79535-47bb-0310-9956-ffa450edef68
2012-06-09 18:53:25 +00:00
Timothy A. Bish 691c70d3ea Add missing license header
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1348352 13f79535-47bb-0310-9956-ffa450edef68
2012-06-09 10:40:52 +00:00
Timothy A. Bish 584c133e9d fix for: https://issues.apache.org/jira/browse/AMQ-3877
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1348270 13f79535-47bb-0310-9956-ffa450edef68
2012-06-08 22:56:35 +00:00
Timothy A. Bish 06a42763c5 On a loaded or very slow machine these can fail without a bit more time on the timeout. Was able to reproduce locally with video encoders running.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1347824 13f79535-47bb-0310-9956-ffa450edef68
2012-06-07 22:59:47 +00:00
Bosanac Dejan 0a8e505b14 https://issues.apache.org/jira/browse/AMQ-3770 - ldap group expansion
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1347649 13f79535-47bb-0310-9956-ffa450edef68
2012-06-07 14:46:27 +00:00
Gary Tully c0a8060ef6 deal with possible null when text marshalled via xstream as munged ctr is used which bypasses default init
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1347621 13f79535-47bb-0310-9956-ffa450edef68
2012-06-07 14:02:00 +00:00
Bosanac Dejan 1f862ba3cd https://issues.apache.org/jira/browse/AMQ-3791 - CachedLDAPAuthorizationMap improvements
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1347580 13f79535-47bb-0310-9956-ffa450edef68
2012-06-07 11:58:40 +00:00
Gary Tully 279ecfcd6d ignore the mqttssl test till it gets some love, it hangs the nigtly run
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1346818 13f79535-47bb-0310-9956-ffa450edef68
2012-06-06 10:48:03 +00:00
Gary Tully 3adee8c076 https://issues.apache.org/jira/browse/AMQ-3872 - avoid property syntax for internal accessor to ensure property equality after seriaization in generated marshalling tests
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1346813 13f79535-47bb-0310-9956-ffa450edef68
2012-06-06 10:29:35 +00:00
Gary Tully b07f31ebc6 https://issues.apache.org/jira/browse/AMQ-3305 and https://issues.apache.org/jira/browse/AMQ-3872 - fix up durable subs with xa recovery for kahadb and tidy up test assumptions re redelivery for jdbc. Shared tests pass with both stores now
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1346594 13f79535-47bb-0310-9956-ffa450edef68
2012-06-05 21:13:34 +00:00
Gary Tully f0d0ce07ab https://issues.apache.org/jira/browse/AMQ-3288 - fix over flow to negative on signed int accumulator, would break priority message deletion
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1346401 13f79535-47bb-0310-9956-ffa450edef68
2012-06-05 14:48:17 +00:00
Gary Tully 64f3492c85 https://issues.apache.org/jira/browse/AMQ-3872 - Implement "exactly once" delivery with JDBC and XA in the event of a failure post prepare. jdbc xa is not a runner due to single table and update locks. implemention adds xid column to messages and acks table. a non null value indicated a prepared add/ack, so the insert is done on prepare. the result of the transaction outcome requires a row level update
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1345202 13f79535-47bb-0310-9956-ffa450edef68
2012-06-01 14:32:50 +00:00
Bosanac Dejan 15f85cd768 https://issues.apache.org/jira/browse/AMQ-2868 - optimize code a bit now that we don't have a sync
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1345034 13f79535-47bb-0310-9956-ffa450edef68
2012-06-01 09:51:48 +00:00
Bosanac Dejan 6d041dc2a5 https://issues.apache.org/jira/browse/AMQ-2868 - remove sync on memoery transaction store tx
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1345023 13f79535-47bb-0310-9956-ffa450edef68
2012-06-01 09:14:28 +00:00
Timothy A. Bish eb887f1545 fix for: https://issues.apache.org/jira/browse/AMQ-3836
Make a best effort to find the correct destination name even if space padded before falling back to the fallback conversion config. 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1344894 13f79535-47bb-0310-9956-ffa450edef68
2012-05-31 20:26:28 +00:00
Timothy A. Bish fd37e8c883 fix for: https://issues.apache.org/jira/browse/AMQ-3871
Fix the addMessageFirst and values methods in OrderedPendingList and add tests for both OrderedPendingList and PrioritizedPendingList along with a test case to show the bad behavior for re-delivered in-flight non-persistent messages with durable subscribers.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1344842 13f79535-47bb-0310-9956-ffa450edef68
2012-05-31 18:14:07 +00:00
Timothy A. Bish 30f677e56a Fix for: https://issues.apache.org/jira/browse/AMQ-3841
Make the call to adapter.getDestinations() only once.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1344778 13f79535-47bb-0310-9956-ffa450edef68
2012-05-31 15:34:59 +00:00
Robert Davies 4d43c74fd2 include mqtt tests
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1343257 13f79535-47bb-0310-9956-ffa450edef68
2012-05-28 13:46:14 +00:00
Timothy A. Bish d44513a655 fix for: https://issues.apache.org/jira/browse/AMQ-3669
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1342028 13f79535-47bb-0310-9956-ffa450edef68
2012-05-23 20:27:23 +00:00
Robert Davies 144dda0308 Additional fixes for https://issues.apache.org/jira/browse/AMQ-3855 - timing issue in adding wildcard subscriptions can result in duplicate messages sent to MQTT
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1341820 13f79535-47bb-0310-9956-ffa450edef68
2012-05-23 10:25:34 +00:00
Timothy A. Bish bed24fabd9 Fix for: https://issues.apache.org/jira/browse/AMQ-3841
Ensure that the mKahaDB cleans up the per-destination kahaDB data when the destination is deleted, and don't throw exceptions in cases where we find an older one that has no destinations in it any longer.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1341601 13f79535-47bb-0310-9956-ffa450edef68
2012-05-22 19:47:23 +00:00
Robert Davies 1e3ea5c9c5 Fix for https://issues.apache.org/jira/browse/AMQ-3855
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1341521 13f79535-47bb-0310-9956-ffa450edef68
2012-05-22 15:22:55 +00:00
Timothy A. Bish fa62da8601 Add autofail to prevent test hang
see: https://issues.apache.org/jira/browse/AMQ-3842

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1340275 13f79535-47bb-0310-9956-ffa450edef68
2012-05-18 22:05:05 +00:00
Timothy A. Bish 53fff528a7 Apply patch for: https://issues.apache.org/jira/browse/AMQ-3817
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1340219 13f79535-47bb-0310-9956-ffa450edef68
2012-05-18 19:30:26 +00:00
Timothy A. Bish 3082a20520 Unit test that reproduces AMQ-3841
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1339660 13f79535-47bb-0310-9956-ffa450edef68
2012-05-17 15:49:32 +00:00
Timothy A. Bish e4d90d9281 Add test to show no issue for: https://issues.apache.org/jira/browse/AMQ-3835
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1339589 13f79535-47bb-0310-9956-ffa450edef68
2012-05-17 13:09:32 +00:00
Timothy A. Bish f13968e97e wait for started before checking on the MBean
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1336387 13f79535-47bb-0310-9956-ffa450edef68
2012-05-09 20:42:06 +00:00
Timothy A. Bish d5c86b0ae5 apply patch for: https://issues.apache.org/jira/browse/AMQ-3822
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1333905 13f79535-47bb-0310-9956-ffa450edef68
2012-05-04 12:23:41 +00:00
Bosanac Dejan c587918821 [maven-release-plugin] prepare for next development iteration
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1332983 13f79535-47bb-0310-9956-ffa450edef68
2012-05-02 10:36:17 +00:00
Bosanac Dejan b7e264f917 [maven-release-plugin] prepare release activemq-5.6.0
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1332981 13f79535-47bb-0310-9956-ffa450edef68
2012-05-02 10:35:43 +00:00
Gary Tully 3307d57528 ensure test is more deterministic and does not hang ci build
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1332977 13f79535-47bb-0310-9956-ffa450edef68
2012-05-02 10:18:29 +00:00
Timothy A. Bish 956724e5cd fix for: https://issues.apache.org/jira/browse/AMQ-3823
Don't trim the whitespace from header values.  Updates the tests to not add spaces in stomp headers. 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1332813 13f79535-47bb-0310-9956-ffa450edef68
2012-05-01 20:54:13 +00:00
Bosanac Dejan e96eab52a1 https://issues.apache.org/jira/browse/AMQ-3819 - handle BUFFER_UNDERFLOW case
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1332230 13f79535-47bb-0310-9956-ffa450edef68
2012-04-30 14:56:09 +00:00
Timothy A. Bish ec87b17be0 test for: https://issues.apache.org/jira/browse/AMQ-3819
Creates a load test based on the user supplied ruby script.  There are four variations, one for each of the transport types.  Tests show that only the Stomp+NIO+SSL fails under this scenario. 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1331481 13f79535-47bb-0310-9956-ffa450edef68
2012-04-27 16:01:20 +00:00
Bosanac Dejan e5c4ffd673 https://issues.apache.org/jira/browse/AMQ-3820 - statistics plugin - subscription statistics
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1331372 13f79535-47bb-0310-9956-ffa450edef68
2012-04-27 12:08:39 +00:00
Bosanac Dejan 710dc7bb20 [maven-release-plugin] prepare for next development iteration
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1329823 13f79535-47bb-0310-9956-ffa450edef68
2012-04-24 16:17:53 +00:00
Bosanac Dejan 96a9fb2502 [maven-release-plugin] prepare release activemq-5.6.0
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1329821 13f79535-47bb-0310-9956-ffa450edef68
2012-04-24 16:17:16 +00:00
Timothy A. Bish 01b9e4bf54 Fix logger declaration.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1329804 13f79535-47bb-0310-9956-ffa450edef68
2012-04-24 15:46:35 +00:00
Bosanac Dejan 6aad9f6bed https://issues.apache.org/jira/browse/AMQ-3679 - add new modules to osgi metadata
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1329662 13f79535-47bb-0310-9956-ffa450edef68
2012-04-24 12:07:00 +00:00
Timothy A. Bish 6a670921b3 Prevent these tests from hanging the hudson build
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1329452 13f79535-47bb-0310-9956-ffa450edef68
2012-04-23 21:12:03 +00:00
Timothy A. Bish 739a13dc2b Make the test more deterministic to fix test errors on slower machines.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1329240 13f79535-47bb-0310-9956-ffa450edef68
2012-04-23 13:50:40 +00:00
Timothy A. Bish 740f5b36da Additional test for: https://issues.apache.org/jira/browse/AMQ-3775
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1329225 13f79535-47bb-0310-9956-ffa450edef68
2012-04-23 13:17:33 +00:00
Gary Tully fc4f01cf5d https://issues.apache.org/jira/browse/AMQ-3805 - fix up unit test regressions with java.util.ConcurrentModificationException due to dispatch no longer being copy on write, shows up need to use iterator in message expiry case
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1328724 13f79535-47bb-0310-9956-ffa450edef68
2012-04-21 18:58:09 +00:00
Gary Tully 6b4d077bdf https://issues.apache.org/jira/browse/AMQ-3805 - further resolution, dispatch and activate could clash over the audit resulting in skipped messages in the batch, the end result being our of order dispatch. Additional test and fix up of use of cache and sync between durable sub and prefetch sub
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1328413 13f79535-47bb-0310-9956-ffa450edef68
2012-04-20 15:36:10 +00:00
Robert Davies 74bed6b577 Fix for https://issues.apache.org/jira/browse/AMQ-3813
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1328287 13f79535-47bb-0310-9956-ffa450edef68
2012-04-20 09:51:55 +00:00
Bosanac Dejan 974f6896a4 fixing licenses
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1327985 13f79535-47bb-0310-9956-ffa450edef68
2012-04-19 15:15:19 +00:00
Gary Tully 2044ade687 reflect the reality of plugable dispatch policys for topics only, https://cwiki.apache.org/confluence/display/ACTIVEMQ/Dispatch+Policies
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1327888 13f79535-47bb-0310-9956-ffa450edef68
2012-04-19 09:35:27 +00:00
Bosanac Dejan 47c392bad3 ExpiredMessagesWithNoConsumerTest - trying to tweak it a bit to prevent failures on slow machines
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1327484 13f79535-47bb-0310-9956-ffa450edef68
2012-04-18 12:40:51 +00:00
Bosanac Dejan 9706f654a4 JobSchedulerStoreTest - fix test, don't allow jobs to start scheduling on slow machines
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1327457 13f79535-47bb-0310-9956-ffa450edef68
2012-04-18 11:47:25 +00:00
Robert Davies 9287816fec fix for https://issues.apache.org/jira/browse/AMQ-796
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1327443 13f79535-47bb-0310-9956-ffa450edef68
2012-04-18 10:52:04 +00:00
Robert Davies 3df43f5886 For https://issues.apache.org/jira/browse/AMQ-3573 In junit tests - fixed null pointer if the directory doesn't exist
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1327388 13f79535-47bb-0310-9956-ffa450edef68
2012-04-18 07:01:50 +00:00
Robert Davies 61fdb188c8 For https://issues.apache.org/jira/browse/AMQ-3573 In junit tests - fixed warning messages can be generated for not enough disk space if the directory doesn't exist
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1327379 13f79535-47bb-0310-9956-ffa450edef68
2012-04-18 05:34:22 +00:00
Robert Davies fb915c3dc6 Fix for https://issues.apache.org/jira/browse/AMQ-3804
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1326692 13f79535-47bb-0310-9956-ffa450edef68
2012-04-16 17:34:00 +00:00
Gary Tully 04aa9c5161 https://issues.apache.org/jira/browse/AMQ-3681 - make use of java.sql.Statement#setQueryTimeout conditional on queryTimeout attribute > 0 so it can be disabled as it does not have universal support, default value 10 seconds
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1326610 13f79535-47bb-0310-9956-ffa450edef68
2012-04-16 13:28:52 +00:00
Robert Davies 7dc2c4e26f Fix for https://issues.apache.org/jira/browse/AMQ-3274
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1326502 13f79535-47bb-0310-9956-ffa450edef68
2012-04-16 06:23:14 +00:00
Robert Davies 0ee0cb9a22 Fix for https://issues.apache.org/jira/browse/AMQ-3678
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1326493 13f79535-47bb-0310-9956-ffa450edef68
2012-04-16 05:47:46 +00:00
Robert Davies 1b9f5f6727 Fix for https://issues.apache.org/jira/browse/AMQ-3004
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1326298 13f79535-47bb-0310-9956-ffa450edef68
2012-04-15 10:36:24 +00:00
Timothy A. Bish 2f0ef2e670 Additional test to show that https://issues.apache.org/jira/browse/AMQ-3802 is a non-issue.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1326200 13f79535-47bb-0310-9956-ffa450edef68
2012-04-14 20:25:00 +00:00
Gary Tully 38666e9298 add autofail to ensure it does not block the hudson build again
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1326021 13f79535-47bb-0310-9956-ffa450edef68
2012-04-13 23:50:47 +00:00
Timothy A. Bish f81a790ff5 apply fix for: https://issues.apache.org/jira/browse/AMQ-3803
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1325985 13f79535-47bb-0310-9956-ffa450edef68
2012-04-13 22:21:27 +00:00
Gary Tully 8d2c079e0c https://issues.apache.org/jira/browse/AMQ-3806 - Partial index updates can lead to bogus recovery for the vmcursor of a Q on startup. Only recovery destinations with that have some messages, so the location index is the system or reference. It makes sense as the location index is the basis for gc
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1325810 13f79535-47bb-0310-9956-ffa450edef68
2012-04-13 15:39:01 +00:00
Gary Tully 90fcbc8812 https://issues.apache.org/jira/browse/AMQ-3630 - NetworkBridgeFilterFactory should be assigned to Queue not NetworkBridge - thanks. the filter should be evaluated per destination
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1325735 13f79535-47bb-0310-9956-ffa450edef68
2012-04-13 12:24:58 +00:00
Gary Tully 53b29a206b https://issues.apache.org/jira/browse/AMQ-3805 - duplicate dispatch to durable sub with concurrent send transaction commit and activate. fixed up the use of audit through an activate/deactivate such that duplicate dispatch is suppressed at source in this case
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1325722 13f79535-47bb-0310-9956-ffa450edef68
2012-04-13 11:47:11 +00:00
Robert Davies 0be51cbfe2 Applied patch for https://issues.apache.org/jira/browse/AMQ-3681
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1325621 13f79535-47bb-0310-9956-ffa450edef68
2012-04-13 05:55:50 +00:00
Bosanac Dejan 7df5c3bdcc ClientRebalanceTest - fix the test to avoid occasional hang
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1324799 13f79535-47bb-0310-9956-ffa450edef68
2012-04-11 15:03:03 +00:00
Timothy A. Bish 0c2144c357 prevent hanging test stalling the build.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1324779 13f79535-47bb-0310-9956-ffa450edef68
2012-04-11 14:23:27 +00:00
Timothy A. Bish 76537741fc Fix for: https://issues.apache.org/jira/browse/AMQ-3788
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1324765 13f79535-47bb-0310-9956-ffa450edef68
2012-04-11 13:54:11 +00:00
Robert Davies 4c3843809e added NIO support to the MQTT protocol for https://issues.apache.org/jira/browse/AMQ-3786
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1324714 13f79535-47bb-0310-9956-ffa450edef68
2012-04-11 11:52:06 +00:00
Timothy A. Bish ff5e7e7626 Remove unneeded tracing that was used for: https://issues.apache.org/jira/browse/AMQ-3775
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1311780 13f79535-47bb-0310-9956-ffa450edef68
2012-04-10 15:12:56 +00:00
Timothy A. Bish 34af42f444 additional fix for: https://issues.apache.org/jira/browse/AMQ-3775
ensure that the messageReferences are calculated correctly when loading a stored destination. 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1311513 13f79535-47bb-0310-9956-ffa450edef68
2012-04-09 22:56:15 +00:00
Timothy A. Bish ccaf0839da additional test for: https://issues.apache.org/jira/browse/AMQ-3775
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1311511 13f79535-47bb-0310-9956-ffa450edef68
2012-04-09 22:50:59 +00:00
Timothy A. Bish 934eaf9923 Test can hang if the async event isn't received, add a timeout in the test loop's wait call to prevent this.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1311402 13f79535-47bb-0310-9956-ffa450edef68
2012-04-09 19:58:13 +00:00
Timothy A. Bish 681c1abf37 add a test for: https://issues.apache.org/jira/browse/AMQ-3802
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1311239 13f79535-47bb-0310-9956-ffa450edef68
2012-04-09 14:11:50 +00:00
Bosanac Dejan 2280719835 https://issues.apache.org/jira/browse/AMQ-3706 - use round-robin instead of rnd for cluster rebalancing
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1311237 13f79535-47bb-0310-9956-ffa450edef68
2012-04-09 14:07:03 +00:00
Timothy A. Bish d112ad5af7 additional test and fix for: https://issues.apache.org/jira/browse/AMQ-3780
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1310559 13f79535-47bb-0310-9956-ffa450edef68
2012-04-06 19:24:33 +00:00
Gary Tully a3f85e271a https://issues.apache.org/jira/browse/AMQ-3775 - ensure no concurrent kahadb transaction in topic store
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1310410 13f79535-47bb-0310-9956-ffa450edef68
2012-04-06 15:50:03 +00:00
Timothy A. Bish 148455413e Add some additional checks and assertions to this test.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1310374 13f79535-47bb-0310-9956-ffa450edef68
2012-04-06 15:00:51 +00:00
Bosanac Dejan 1c0dbd1a1e https://issues.apache.org/jira/browse/AMQ-3801 - job scheduler index corruption
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1309780 13f79535-47bb-0310-9956-ffa450edef68
2012-04-05 11:35:57 +00:00
Robert Davies 0f5b406b43 more functionality for MQTT for https://issues.apache.org/jira/browse/AMQ-3786
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1309566 13f79535-47bb-0310-9956-ffa450edef68
2012-04-04 19:46:26 +00:00
Gary Tully 6110e16f28 fix intermittent ci failure, remove dependency on free jmx rmi port
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1307340 13f79535-47bb-0310-9956-ffa450edef68
2012-03-30 10:02:26 +00:00
Gary Tully 33cdefaf2e https://issues.apache.org/jira/browse/AMQ-3792: use of the failover transport incorrectly suppresses javax.jms.InvalidClientIDException when clientId is already in use. fixup with test and fix to test dependent on wrong behaviour
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1307142 13f79535-47bb-0310-9956-ffa450edef68
2012-03-29 22:05:18 +00:00
Timothy A. Bish c6ec76e6f6 small cleanup: https://issues.apache.org/jira/browse/AMQ-3775
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1306886 13f79535-47bb-0310-9956-ffa450edef68
2012-03-29 14:49:31 +00:00
Gary Tully 81e1de95f8 https://issues.apache.org/jira/browse/AMQ-3473: add defensive null check for brokerservice and region broker in case of dup detection during initalisation or partially initialised test, pa is always eagerly created
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1306865 13f79535-47bb-0310-9956-ffa450edef68
2012-03-29 13:43:18 +00:00
Gary Tully b137af4f8a https://issues.apache.org/jira/browse/AMQ-3786 - disable tests pending commit of activemq-core/src/test/resources/org/apache/activemq/transport/mqtt dependency
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1306785 13f79535-47bb-0310-9956-ffa450edef68
2012-03-29 11:20:00 +00:00
Gary Tully fb0b63e379 https://issues.apache.org/jira/browse/AMQ-3473 - Messages (possibly) stuck and pending messages count showing high number of pending message which do not get sent to a consumer. resolve the error in queue stats, message count and enqueue count when index suppressed a duplicate message add attempt
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1306228 13f79535-47bb-0310-9956-ffa450edef68
2012-03-28 09:41:50 +00:00
Gary Tully 1575f45897 ensure test starts with a clean slate, fix intermittent failure in hudson
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1305288 13f79535-47bb-0310-9956-ffa450edef68
2012-03-26 10:05:36 +00:00
Robert Davies cfc6917a79 intial files to support MQTT -see https://issues.apache.org/jira/browse/AMQ-3786
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1304984 13f79535-47bb-0310-9956-ffa450edef68
2012-03-25 06:33:49 +00:00
Gary Tully c3e57ec9fd resolve persistent hudson failure of org.apache.activemq.network.SimpleNetworkTest.testConduitBridge - individual cases were interfering with each other. A secondary failure, org.apache.activemq.network.SimpleNetworkTest#testDurableStoreAndForwardReconnect shows a problem with consuming an existing sub across a network, it won't work. It is not trivial to fix either, so virtual topics are a better bet in a network environment atm
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1304559 13f79535-47bb-0310-9956-ffa450edef68
2012-03-23 18:53:18 +00:00
Timothy A. Bish d92d3a8a06 fix for: https://issues.apache.org/jira/browse/AMQ-3782
avoid any potential NPE and try again.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1304057 13f79535-47bb-0310-9956-ffa450edef68
2012-03-22 21:00:17 +00:00
Gary Tully 1463bec066 https://issues.apache.org/jira/browse/AMQ-3768: ClassCastException when running some Durable Consumer test cases. root cause of the classcast was the reuse of a freed node that was still referenced as the head page id of a listindex. The fix is to not modify the head page id of a listindex when removing and coalescing linked pages, the head page remains valid for the duration of a subscription. Eventually got a test case that could easlily reproduce
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1304020 13f79535-47bb-0310-9956-ffa450edef68
2012-03-22 20:01:40 +00:00
Timothy A. Bish 5cd9ebaeb7 fis for: https://issues.apache.org/jira/browse/AMQ-3718
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1303544 13f79535-47bb-0310-9956-ffa450edef68
2012-03-21 19:55:30 +00:00
Timothy A. Bish 3cea40d889 https://issues.apache.org/jira/browse/AMQ-3775
Ensure that the orderIndex is reset to a good state. 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1303128 13f79535-47bb-0310-9956-ffa450edef68
2012-03-20 20:10:59 +00:00
Timothy A. Bish 1419103c18 https://issues.apache.org/jira/browse/AMQ-3775
Update test to not use a static port for the broker Uri.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1303113 13f79535-47bb-0310-9956-ffa450edef68
2012-03-20 19:26:54 +00:00
Timothy A. Bish 926fdd7e92 fix and test for: https://issues.apache.org/jira/browse/AMQ-3780
ensure that non-persistent messages are cleaned up from temp storage when the Queue is deleted.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1302977 13f79535-47bb-0310-9956-ffa450edef68
2012-03-20 16:26:07 +00:00
Robert Davies 1d7b69d55c Added package.html for levelDB stub - for https://issues.apache.org/jira/browse/AMQ-3772
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1302912 13f79535-47bb-0310-9956-ffa450edef68
2012-03-20 14:24:04 +00:00
Timothy A. Bish cdacf82428 fix bad logger define.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1302910 13f79535-47bb-0310-9956-ffa450edef68
2012-03-20 14:19:56 +00:00
Robert Davies bd5124cf94 Added config test for LevelDB - for https://issues.apache.org/jira/browse/AMQ-3772
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1302904 13f79535-47bb-0310-9956-ffa450edef68
2012-03-20 14:06:37 +00:00
Robert Davies ca83305faa add property optimizeMessageStoreInFlightLimit on destinations so can set the inflight limit above which optimize store dispatch is no longer applied - for https://issues.apache.org/jira/browse/AMQ-3750
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1302887 13f79535-47bb-0310-9956-ffa450edef68
2012-03-20 13:40:03 +00:00
Timothy A. Bish 13e5777efb additional test for: https://issues.apache.org/jira/browse/AMQ-3775
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1302641 13f79535-47bb-0310-9956-ffa450edef68
2012-03-19 20:23:51 +00:00
Timothy A. Bish 0af0021d0b fix and test for: https://issues.apache.org/jira/browse/AMQ-3775
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1302607 13f79535-47bb-0310-9956-ffa450edef68
2012-03-19 19:23:12 +00:00
Robert Davies 08b95689cb updated for https://issues.apache.org/jira/browse/AMQ-3772
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1302494 13f79535-47bb-0310-9956-ffa450edef68
2012-03-19 15:01:12 +00:00
Gary Tully 1be93984a2 https://issues.apache.org/jira/browse/AMQ-3733: Topic subscriber is assumed to be slow consumer when prefetch is set to one. Thanks for the great test case. Fixed up the logic used to determine slowness of a sub to take into account the pending messages and prefetch. It is now only applicable when prefetch > 1 and the pending message strategy keeps messages in memory
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1301565 13f79535-47bb-0310-9956-ffa450edef68
2012-03-16 14:55:38 +00:00
Hiram R. Chirino d4cd7f9eed Fixes AMQ-3769: Support doing non-blocking sends that uses an async callback that gets notified when the send has been received by the broker
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1300727 13f79535-47bb-0310-9956-ffa450edef68
2012-03-14 21:32:18 +00:00
Timothy A. Bish a7e7bce0ae fix and test for: https://issues.apache.org/jira/browse/AMQ-3719
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1300726 13f79535-47bb-0310-9956-ffa450edef68
2012-03-14 21:31:25 +00:00
Timothy A. Bish 3a5b48a4db fix for: https://issues.apache.org/jira/browse/AMQ-3732
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1297252 13f79535-47bb-0310-9956-ffa450edef68
2012-03-05 22:08:51 +00:00
Gary Tully 09ff99fbfa https://issues.apache.org/jira/browse/AMQ-1706 - fix up doc comment
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1297025 13f79535-47bb-0310-9956-ffa450edef68
2012-03-05 12:16:40 +00:00
Timothy A. Bish 0efaaecfd1 fix for: https://issues.apache.org/jira/browse/AMQ-1905
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1296720 13f79535-47bb-0310-9956-ffa450edef68
2012-03-03 23:30:09 +00:00
Timothy A. Bish 686bfcf496 fix for: https://issues.apache.org/jira/browse/AMQ-1907
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1296711 13f79535-47bb-0310-9956-ffa450edef68
2012-03-03 21:51:38 +00:00
Timothy A. Bish d40f398b31 fix for: https://issues.apache.org/jira/browse/AMQ-3750
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1296469 13f79535-47bb-0310-9956-ffa450edef68
2012-03-02 21:11:30 +00:00
Gary Tully ac54a611f3 ensure broker stop ocurrs after subs connected and add defensive check to close identified by one failure scenario
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1296396 13f79535-47bb-0310-9956-ffa450edef68
2012-03-02 19:15:45 +00:00
Gary Tully d2f8eded57 fix timing issue with test, fails under load
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1296368 13f79535-47bb-0310-9956-ffa450edef68
2012-03-02 18:31:45 +00:00
Gary Tully 9b7347087d make test more deterministic
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1296326 13f79535-47bb-0310-9956-ffa450edef68
2012-03-02 17:30:44 +00:00
Gary Tully df8d1e824d https://issues.apache.org/jira/browse/AMQ-3749 - Composite destinations break simple authorisation through role aggregation. additional tests and fix - fix broken test, expecting wrong behaviour
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1296204 13f79535-47bb-0310-9956-ffa450edef68
2012-03-02 13:53:31 +00:00
Torsten Mielke 14110f52eb AMQ-3754: Updated org.apache.activemq.transport.vm.VmTransportNetworkBrokerTest
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1296194 13f79535-47bb-0310-9956-ffa450edef68
2012-03-02 13:20:14 +00:00
Gary Tully 783ba853aa fix intermittent hang if all threads do not complete on time
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1296157 13f79535-47bb-0310-9956-ffa450edef68
2012-03-02 11:46:31 +00:00
Robert Davies f4d4c3b4ce Fix for https://issues.apache.org/jira/browse/AMQ-3750 - add hint to storage of messages to enable concurrent store and dispatch
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1295662 13f79535-47bb-0310-9956-ffa450edef68
2012-03-01 16:37:19 +00:00
Gary Tully 5dda6e6fee https://issues.apache.org/jira/browse/AMQ-3749 - Composite destinations break simple authorisation through role aggregation. additional tests and fix - ldap did need some work
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1295661 13f79535-47bb-0310-9956-ffa450edef68
2012-03-01 16:36:12 +00:00
Gary Tully 9a7443a137 https://issues.apache.org/jira/browse/AMQ-3749 - Composite destinations break simple authorisation through role aggregation. additional tests and fix, the union of the roles for composite destinations provides the auth list
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1295545 13f79535-47bb-0310-9956-ffa450edef68
2012-03-01 13:06:45 +00:00
Gary Tully 503e1dc15e https://issues.apache.org/jira/browse/AMQ-3747 - Syntax errors are not showing up in the log when the broker is started in the background. fix by logging a fatalbeanexception on context creation before rethrow
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1295138 13f79535-47bb-0310-9956-ffa450edef68
2012-02-29 14:45:32 +00:00
Timothy A. Bish e426de8c32 fix for: https://issues.apache.org/jira/browse/AMQ-3742 with supplied unit test patch applied.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1294342 13f79535-47bb-0310-9956-ffa450edef68
2012-02-27 21:37:03 +00:00
Gary Tully 2290502bc9 https://issues.apache.org/jira/browse/AMQ-3737 - Possible leak in ManangedRegionBroker unregisterDestination. relates to: https://issues.apache.org/activemq/browse/AMQ-2741 - a leak indeed, or more than a mbean
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1292858 13f79535-47bb-0310-9956-ffa450edef68
2012-02-23 17:13:37 +00:00
Timothy A. Bish f5dcc9dfbf fix for: https://issues.apache.org/jira/browse/AMQ-3734
Adds username to some MBeans when enabled in BrokerService to allow for tracking of the authenticated user of connections and other resources.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1292599 13f79535-47bb-0310-9956-ffa450edef68
2012-02-23 00:40:13 +00:00
Timothy A. Bish 3221b16221 fix for: https://issues.apache.org/jira/browse/AMQ-3731
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1291465 13f79535-47bb-0310-9956-ffa450edef68
2012-02-20 21:47:59 +00:00
Gary Tully e32ff5c7f4 https://issues.apache.org/jira/browse/AMQ-3729 - Stomp wireformat and codec block on telnet CRLF CRLF header separator. fix up telnet support, additional test, impacts https://issues.apache.org/jira/browse/AMQ-2583 and https://issues.apache.org/jira/browse/AMQ-3449
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1291299 13f79535-47bb-0310-9956-ffa450edef68
2012-02-20 14:58:23 +00:00
Timothy A. Bish df19a382c9 fix for: https://issues.apache.org/jira/browse/AMQ-2834
Adds some checks on store limit vs journal max file size similar to the Temp Store limit checks

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1245777 13f79535-47bb-0310-9956-ffa450edef68
2012-02-17 21:50:45 +00:00
Gary Tully 9f0a673e36 order is not guarenteed with multiple consumers, just validate quantity
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1245408 13f79535-47bb-0310-9956-ffa450edef68
2012-02-17 11:37:12 +00:00
Gary Tully 49dd85c5e7 reduce default number of restarts and down time to reduce duration
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1244976 13f79535-47bb-0310-9956-ffa450edef68
2012-02-16 13:53:32 +00:00
Gary Tully cc7ea7f31f reduce test duration from crazy 30 minutes, validate temp store being used
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1244974 13f79535-47bb-0310-9956-ffa450edef68
2012-02-16 13:40:47 +00:00
Timothy A. Bish 08ae7770bb fix: https://issues.apache.org/jira/browse/AMQ-3721
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1244809 13f79535-47bb-0310-9956-ffa450edef68
2012-02-16 00:40:55 +00:00
Timothy A. Bish 97ae32388c fix for: https://issues.apache.org/jira/browse/AMQ-3714 lazy init the Scheduler object in ActiveMQConnection.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1244796 13f79535-47bb-0310-9956-ffa450edef68
2012-02-16 00:02:15 +00:00
Gary Tully 98b7dcdd1d fix intermittent failure, consume messages from all destinations, sorts out the composite case so that there are no dangling messages
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1244443 13f79535-47bb-0310-9956-ffa450edef68
2012-02-15 11:21:43 +00:00
Timothy A. Bish 1638801522 Add an initial port of ConcurrentProducerDurableConsumerTest to performance test Queue dispatch.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1244290 13f79535-47bb-0310-9956-ffa450edef68
2012-02-15 00:29:39 +00:00
Timothy A. Bish a3060e79d9 https://issues.apache.org/jira/browse/AMQ-3706
Don't send a URI to the client that equals "null" when the BrokerInfo has no set Broker URI, that sends the failover transport into an infinite reconnect cycle.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1244221 13f79535-47bb-0310-9956-ffa450edef68
2012-02-14 21:36:04 +00:00
Gary Tully 8bff980ec2 remove typo ref to backport timeunit - https://issues.apache.org/jira/browse/AMQ-3684
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1244117 13f79535-47bb-0310-9956-ffa450edef68
2012-02-14 16:38:08 +00:00
Gary Tully 2a87ad5b3e https://issues.apache.org/jira/browse/AMQ-3716: NetworkBridge with conduitSubscriptions=true will leak consumer info in org.apache.activemq.network.DemandForwardingBridgeSupport#subscriptionMapByRemoteId map. fix with test
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1244116 13f79535-47bb-0310-9956-ffa450edef68
2012-02-14 16:37:29 +00:00
Timothy A. Bish 456005bf13 Mark this as @Deprecated as its not used anymore in AMQ and should be removed.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1243716 13f79535-47bb-0310-9956-ffa450edef68
2012-02-13 22:12:11 +00:00
Timothy A. Bish ad585dc4b0 Refactoed the VMTransport for: https://issues.apache.org/jira/browse/AMQ-3684
Adds a test for basic functionality tests on the VMTransport.  

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1243706 13f79535-47bb-0310-9956-ffa450edef68
2012-02-13 21:56:50 +00:00
Gary Tully ace122aede ensure test failure does not block build
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1243485 13f79535-47bb-0310-9956-ffa450edef68
2012-02-13 11:53:28 +00:00
Gary Tully 9a22fe586d ensure frames are null terminated
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1243484 13f79535-47bb-0310-9956-ffa450edef68
2012-02-13 11:52:11 +00:00
Gary Tully 5a74d56cc1 https://issues.apache.org/jira/browse/AMQ-3684 - revert initialisation order, thread can be eager and needs complete state so it must be inited last
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1243334 13f79535-47bb-0310-9956-ffa450edef68
2012-02-12 21:09:12 +00:00
Gary Tully bc8441bebc https://issues.apache.org/jira/browse/AMQ-3684 - resolve deadlock on blocked oneway, revise sync and lazy init, remove use of valve
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1242912 13f79535-47bb-0310-9956-ffa450edef68
2012-02-10 20:19:44 +00:00
Gary Tully 93a379fe3c https://issues.apache.org/jira/browse/AMQ-3653 - tidy up stomptest and resolve content length for stomp+nio, resolve break of stompnio and stompniossl tests
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1242911 13f79535-47bb-0310-9956-ffa450edef68
2012-02-10 20:18:50 +00:00
Bosanac Dejan beda82ad5a https://issues.apache.org/jira/browse/AMQ-3706 - balance randomize with cluster update
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1242748 13f79535-47bb-0310-9956-ffa450edef68
2012-02-10 11:48:56 +00:00
Timothy A. Bish 2cb8ed221b add test case from: https://issues.apache.org/jira/browse/AMQ-3359
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1242386 13f79535-47bb-0310-9956-ffa450edef68
2012-02-09 16:36:48 +00:00
Timothy A. Bish c062020bcb add a test to show that https://issues.apache.org/jira/browse/AMQ-3445 is not an issue in trunk.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1241935 13f79535-47bb-0310-9956-ffa450edef68
2012-02-08 15:28:52 +00:00
Gary Tully 9d15861cce https://issues.apache.org/jira/browse/AMQ-3695 - remove distinct qualifier from union, breaks oracle and is the default
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1241869 13f79535-47bb-0310-9956-ffa450edef68
2012-02-08 11:21:39 +00:00
Timothy A. Bish 6a631a9d21 fix and test for: https://issues.apache.org/jira/browse/AMQ-3705
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1241629 13f79535-47bb-0310-9956-ffa450edef68
2012-02-07 21:18:50 +00:00
Bosanac Dejan 19cb932816 https://issues.apache.org/jira/browse/AMQ-3685 - a few more fixes for failover cluster update ... handle well original broker restarting and avoid deadlock
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1241426 13f79535-47bb-0310-9956-ffa450edef68
2012-02-07 11:24:49 +00:00
Timothy A. Bish b567bd478b fix for: https://issues.apache.org/jira/browse/AMQ-3703
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1241246 13f79535-47bb-0310-9956-ffa450edef68
2012-02-06 22:54:47 +00:00
Timothy A. Bish cdba931deb fix for: https://issues.apache.org/jira/browse/AMQ-3702
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1241221 13f79535-47bb-0310-9956-ffa450edef68
2012-02-06 22:24:58 +00:00
Timothy A. Bish a1d5ff0316 fix for: for: https://issues.apache.org/jira/browse/AMQ-3700
Prevent any calls to wakeup becoming recursive calls into iterate() and instead queue a wakeup so that we don't miss dispatching any messages as things change in the memory usage.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1241077 13f79535-47bb-0310-9956-ffa450edef68
2012-02-06 16:59:07 +00:00
Timothy A. Bish 1a566ecff7 Test case for: https://issues.apache.org/jira/browse/AMQ-3700
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1241073 13f79535-47bb-0310-9956-ffa450edef68
2012-02-06 16:51:01 +00:00
Gary Tully 80ecfb7049 test case that shows concurrent mod exception when optimise dispatch is enabled and usage limit met
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1241068 13f79535-47bb-0310-9956-ffa450edef68
2012-02-06 16:37:09 +00:00
Bosanac Dejan 7388438a85 https://issues.apache.org/jira/browse/AMQ-3699 - priority uris for failover transport
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1241061 13f79535-47bb-0310-9956-ffa450edef68
2012-02-06 16:25:44 +00:00
Gary Tully e73230b4a3 https://issues.apache.org/jira/browse/AMQ-3695 - ensure destination deletion removes entry in the acks table
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1240994 13f79535-47bb-0310-9956-ffa450edef68
2012-02-06 12:05:17 +00:00
Gary Tully c35550f165 https://issues.apache.org/jira/browse/AMQ-3695 - fix up two related/inherited tests
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1240979 13f79535-47bb-0310-9956-ffa450edef68
2012-02-06 11:22:04 +00:00
Gary Tully 24c4257998 this test causes hudson to hang, disabling pending investigation into root cause
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1240973 13f79535-47bb-0310-9956-ffa450edef68
2012-02-06 10:49:15 +00:00
Timothy A. Bish f220607e33 fix for: https://issues.apache.org/jira/browse/AMQ-3586
Trim whitespace from destination names

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1240287 13f79535-47bb-0310-9956-ffa450edef68
2012-02-03 18:46:03 +00:00
Timothy A. Bish 65fe5e2587 Update the test to address hanging in hudson
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1240188 13f79535-47bb-0310-9956-ffa450edef68
2012-02-03 14:24:17 +00:00
Gary Tully b6f63b0d10 https://issues.apache.org/jira/browse/AMQ-3695: Failover using a JDBC Message Store and Virtual Topic can result in a lost message if queue is empty. Problem is that an empty destination is not recorded, as there is no entry in the messages table. Fix is to make use of the ack table, in the same way a for durable subs. For destinations that match the virtual topic filter, an entry out of priority range is added to the ack table. the startup destination query now unions over the ack and messages table
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1240162 13f79535-47bb-0310-9956-ffa450edef68
2012-02-03 13:43:36 +00:00
Timothy A. Bish f6caba7127 Additional Fix for https://issues.apache.org/jira/browse/AMQ-3573 - Avoid a potential NPE.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1239335 13f79535-47bb-0310-9956-ffa450edef68
2012-02-01 21:39:37 +00:00
Timothy A. Bish d403f10722 Additional Fix for https://issues.apache.org/jira/browse/AMQ-3573 - Add check for improperly configured temp store limits
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1239319 13f79535-47bb-0310-9956-ffa450edef68
2012-02-01 20:57:36 +00:00
Timothy A. Bish b11f1b452d Adds a test that verifies the behavior of the temp store when setting limits smaller than the max journal file size.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1239308 13f79535-47bb-0310-9956-ffa450edef68
2012-02-01 20:26:31 +00:00
Timothy A. Bish e25e5dee86 Update test so that its not using a fixed port for the brokerUri.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1239283 13f79535-47bb-0310-9956-ffa450edef68
2012-02-01 19:37:29 +00:00
Gary Tully 179d95e7be https://issues.apache.org/jira/browse/AMQ-3694 - Blocked/Slow advisory consumers in duplex network connector, eventually breaks request/reply with temps. The duplex case was not acking advisory messages, so we were limited to 750! Also revisit association of producer created temp with connection as this can still get deleted before an advisory. Solution is to let gc pick up temps created in this way, https://issues.apache.org/jira/browse/AMQ-2571. Resolve contention on destination creation for producer/advisory race condition. Additional tests
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1239188 13f79535-47bb-0310-9956-ffa450edef68
2012-02-01 16:11:17 +00:00
Bosanac Dejan 91059de283 https://issues.apache.org/jira/browse/AMQ-3685 - fixing cluster update feature
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1239118 13f79535-47bb-0310-9956-ffa450edef68
2012-02-01 13:12:33 +00:00
Timothy A. Bish bc78238ad0 fix for: https://issues.apache.org/jira/browse/AMQ-3137
fix for: https://issues.apache.org/jira/browse/AMQ-2455
fix for: https://issues.apache.org/jira/browse/AMQ-3635

Adds reconnect logic and tests along with a policy class to allow for control over the reconnect process.
Reconnection of both local and foreign side of the JmsConnector is supported.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1238827 13f79535-47bb-0310-9956-ffa450edef68
2012-01-31 21:56:03 +00:00
Gary Tully d1357b4970 https://issues.apache.org/jira/browse/AMQ-3467 - fix auto upgrade from version 3 to version 4 of kahaDb, existing durable subs messages were lost, additional test
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1236905 13f79535-47bb-0310-9956-ffa450edef68
2012-01-27 22:02:13 +00:00
Bosanac Dejan 4d3af76ee6 https://issues.apache.org/jira/browse/AMQ-3685 - sanitize brokerUrl in BrokerInfo as it can break failover url when cluster update is used
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1236707 13f79535-47bb-0310-9956-ffa450edef68
2012-01-27 15:08:23 +00:00
Gary Tully 3b19c71935 https://issues.apache.org/jira/browse/AMQ-3573: fix up test
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1236666 13f79535-47bb-0310-9956-ffa450edef68
2012-01-27 12:59:47 +00:00
Gary Tully e901d2fd2e https://issues.apache.org/jira/browse/AMQ-3684 - Potential deadlock in vm transport setListener when sender is blocked pending space
Deal with the case of blocked producer

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1236664 13f79535-47bb-0310-9956-ffa450edef68
2012-01-27 12:53:09 +00:00
Gary Tully dcf1f5e0cc https://issues.apache.org/jira/browse/AMQ-3634 - ensure full recovery of the index, irrespective of the load failure reason, with additional tests. Shutdown the schedualler early to ensure no ugly errors from timer tasks during shutdown
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1236661 13f79535-47bb-0310-9956-ffa450edef68
2012-01-27 12:47:39 +00:00
Timothy A. Bish c4c9cf2e94 fix for: https://issues.apache.org/jira/browse/AMQ-3683
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1236414 13f79535-47bb-0310-9956-ffa450edef68
2012-01-26 22:18:59 +00:00
Bosanac Dejan 55fa377f2f https://issues.apache.org/jira/browse/AMQ-3682 - use jmxLocal for karaf commands by default
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1236227 13f79535-47bb-0310-9956-ffa450edef68
2012-01-26 15:10:57 +00:00
Bosanac Dejan a1e961d09c remove kahadb store dependency on activeio
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1235701 13f79535-47bb-0310-9956-ffa450edef68
2012-01-25 09:31:08 +00:00
Timothy A. Bish 4d480c9239 Add fix : https://issues.apache.org/jira/browse/AMQ-3674
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1235530 13f79535-47bb-0310-9956-ffa450edef68
2012-01-24 22:18:29 +00:00
Timothy A. Bish 5aa8b30c0f fix and test for: https://issues.apache.org/jira/browse/AMQ-3675
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1235481 13f79535-47bb-0310-9956-ffa450edef68
2012-01-24 20:37:06 +00:00
Timothy A. Bish eec1091c45 Add fix and test for: https://issues.apache.org/jira/browse/AMQ-3674
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1235341 13f79535-47bb-0310-9956-ffa450edef68
2012-01-24 16:38:03 +00:00
Timothy A. Bish 7b90f4178f additional fix for: https://issues.apache.org/jira/browse/AMQ-3573
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1235325 13f79535-47bb-0310-9956-ffa450edef68
2012-01-24 16:14:37 +00:00
Robert Davies dbc661fd9b Fix for https://issues.apache.org/jira/browse/AMQ-3573 -
changed defaults for SystemUsage to
50GB for temp usage, 100GB for store usage and 64mb for memory usage.
Added error and warning messages if the SysteMUsage limits cannot be met by the system

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1235261 13f79535-47bb-0310-9956-ffa450edef68
2012-01-24 14:22:58 +00:00
Timothy A. Bish 1d52f3b53c fix for: https://issues.apache.org/jira/browse/AMQ-3673
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1234981 13f79535-47bb-0310-9956-ffa450edef68
2012-01-23 20:46:50 +00:00
Timothy A. Bish 999dc0df20 fix for: https://issues.apache.org/jira/browse/AMQ-3672
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1234010 13f79535-47bb-0310-9956-ffa450edef68
2012-01-20 17:12:54 +00:00
Bosanac Dejan e3a1fc9b35 https://issues.apache.org/jira/browse/AMQ-3670 - fix stomp nack support
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1233860 13f79535-47bb-0310-9956-ffa450edef68
2012-01-20 10:59:05 +00:00
Gary Tully e02dfdeaad move test to KahaDb and add simple validation of sendFailIfNoSpace and temp usage for non persistent messages. Producer stops on the exception, consumer picks up all the messages
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1233367 13f79535-47bb-0310-9956-ffa450edef68
2012-01-19 13:33:19 +00:00
Gary Tully eca00f9ab9 findbugs: fix infinite recursion - remove unused method
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1233366 13f79535-47bb-0310-9956-ffa450edef68
2012-01-19 13:32:53 +00:00
Gary Tully 7eb8f0fd73 findbugs: fix infinite recursion
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1233354 13f79535-47bb-0310-9956-ffa450edef68
2012-01-19 13:21:27 +00:00
Timothy A. Bish 5774d004f8 https://issues.apache.org/jira/browse/AMQ-3653
Fix the test so that there's time for the Ack to be processed before the connection is closed otherwise it can be missed.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1232457 13f79535-47bb-0310-9956-ffa450edef68
2012-01-17 16:14:16 +00:00
Gary Tully 221da8bcd2 https://issues.apache.org/jira/browse/AMQ-3639 - Modify MKahaDB To Support Using One Adapter Per Destination Without Explicity Listing Every Desintation In The Configuration. Add perDestination boolean attribute to mKahaDb filtered adapter. When true, every destination will get its own persistence adapter using the configured adapter as as template. So any config applied to the destination less (default) adapter will be reused
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1231979 13f79535-47bb-0310-9956-ffa450edef68
2012-01-16 12:47:45 +00:00
Timothy A. Bish 71e228fe92 fix for NPE: https://issues.apache.org/jira/browse/AMQ-3649
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1231081 13f79535-47bb-0310-9956-ffa450edef68
2012-01-13 14:10:11 +00:00
Timothy A. Bish 0e95460e0a Update Javadoc for: https://issues.apache.org/jira/browse/AMQ-3652
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1227591 13f79535-47bb-0310-9956-ffa450edef68
2012-01-05 13:46:09 +00:00
Bosanac Dejan a35fdd13fb https://issues.apache.org/jira/browse/AMQ-3653 - content-length in ack frames
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1227577 13f79535-47bb-0310-9956-ffa450edef68
2012-01-05 13:00:00 +00:00
Hiram R. Chirino 71d5fef019 Fixes AMQ-3651 : If the broker binds RMI registry port when it starts up, the broker should release RMI registry port when it shuts down
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1227186 13f79535-47bb-0310-9956-ffa450edef68
2012-01-04 15:20:55 +00:00
Hiram R. Chirino 1753a699e0 Allow attaching an entryLocator and dataLocator to message ids. These fields are for message stores to associate store keys with messages ids when the messages
get persisted to disk.  Should allow stores to perform faster message loads since the store may be able to bypass a key lookup.



git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1227185 13f79535-47bb-0310-9956-ffa450edef68
2012-01-04 15:16:11 +00:00
Hiram R. Chirino d95658f4b4 Allow LRUCache subclasses to trap eviction events
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1227183 13f79535-47bb-0310-9956-ffa450edef68
2012-01-04 15:12:58 +00:00
Hiram R. Chirino 78761cb348 Remove trailing ; at end of class declaration.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1226974 13f79535-47bb-0310-9956-ffa450edef68
2012-01-03 22:31:38 +00:00
Gary Tully 89f22dacac https://issues.apache.org/jira/browse/AMQ-3646 - Allow KahaDB to run without disk syncs, higher through put without the jms persistence guarantee. Allow 0 peroid to disable checkpoint/cleanup. Allow jmx gc operation to invoke cleanup so that store gc can be initiated via jms to ensure disk is reclaimed. Ensure periodic checkpoint does not sync when enableJournalDiskSyncs=false, it waits for completion but does not force to disk. fix cached buffer allocation and refactor to reuse more code in CallerBufferingDataFileAppender
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1222705 13f79535-47bb-0310-9956-ffa450edef68
2011-12-23 15:44:52 +00:00
Gary Tully 384388fe62 CallerBufferingDataFileAppender, fix rollover of cached buffers
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1222635 13f79535-47bb-0310-9956-ffa450edef68
2011-12-23 10:48:38 +00:00
Gary Tully bb4a2f73f4 add experimental appender that takes the buffering burden from the writer thread, it and some trace enabled via -Dorg.apache.kahadb.journal.appender.WRITE_STAT_WINDOW=10000 -Dorg.apache.kahadb.journal.CALLER_BUFFER_APPENDER=true. Additional accessors on KahaDb to further configure index for the fast but may need recovery case
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1222471 13f79535-47bb-0310-9956-ffa450edef68
2011-12-22 21:44:01 +00:00
Timothy A. Bish cb1b92bf58 apply patch and add test for: https://issues.apache.org/jira/browse/AMQ-3436
Some modifications needed for the patch to work correctly.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1222275 13f79535-47bb-0310-9956-ffa450edef68
2011-12-22 15:15:48 +00:00
Timothy A. Bish d97e8fe354 Replace the System.out calls with loggers.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1222250 13f79535-47bb-0310-9956-ffa450edef68
2011-12-22 14:23:25 +00:00
Gary Tully 323eeda725 add scenario test for fast persistent enqueues to explore getting the broker to be disk bound
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1222219 13f79535-47bb-0310-9956-ffa450edef68
2011-12-22 13:22:25 +00:00
Timothy A. Bish 5cc1a557ff fix for: https://issues.apache.org/jira/browse/AMQ-3625
Ensure that incoming commands get exception responses after the initial error is triggered so that client transports don't block wia intg for responses.  

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1221484 13f79535-47bb-0310-9956-ffa450edef68
2011-12-20 20:42:18 +00:00
Timothy A. Bish c856f30bc5 fix for: https://issues.apache.org/jira/browse/AMQ-3625
applied patch to add the supplied test case.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1221310 13f79535-47bb-0310-9956-ffa450edef68
2011-12-20 15:12:11 +00:00
Bosanac Dejan c534900092 https://issues.apache.org/jira/browse/AMQ-3496 - reply-to header for Stomp - fix test
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1221222 13f79535-47bb-0310-9956-ffa450edef68
2011-12-20 12:19:29 +00:00
Bosanac Dejan 1c264085d1 https://issues.apache.org/jira/browse/AMQ-3496 - reply-to header for Stomp
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1221199 13f79535-47bb-0310-9956-ffa450edef68
2011-12-20 11:06:40 +00:00
Gary Tully 882c5539d1 get a recept on send to ensure message gets there
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1220724 13f79535-47bb-0310-9956-ffa450edef68
2011-12-19 12:54:38 +00:00
Robert Davies 7da61d992f commit patch for https://issues.apache.org/jira/browse/AMQ-3618
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1215433 13f79535-47bb-0310-9956-ffa450edef68
2011-12-17 07:05:46 +00:00
Timothy A. Bish 68bcf0fb15 fix for: https://issues.apache.org/jira/browse/AMQ-3615
Reduce contention by not sending an advisory for every destination when not all destination types are requested.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1214964 13f79535-47bb-0310-9956-ffa450edef68
2011-12-15 21:49:44 +00:00
Gary Tully 41cdadbe2a https://issues.apache.org/jira/browse/AMQ-3637 - NullPointerException while loading node from kahadb during vmcursor replay. Batch recovery such that expiry can be processed periodically which avoids a nested kahadb transaction that modifies. additional test and some additional logging when recovery is taking a long time
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1214888 13f79535-47bb-0310-9956-ffa450edef68
2011-12-15 17:44:47 +00:00
Bosanac Dejan ecb10e9519 fix for DuplexNetworkTest failure
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1214700 13f79535-47bb-0310-9956-ffa450edef68
2011-12-15 11:10:07 +00:00
Timothy A. Bish 802f6b193a fix for: https://issues.apache.org/jira/browse/AMQ-3605
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1213979 13f79535-47bb-0310-9956-ffa450edef68
2011-12-13 23:13:35 +00:00
Bosanac Dejan 5f7fc14e2e https://issues.apache.org/jira/browse/AMQ-3634 - corrupted index recovery
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1213743 13f79535-47bb-0310-9956-ffa450edef68
2011-12-13 15:43:53 +00:00
Timothy A. Bish cfcd4f7f64 apply patch for: https://issues.apache.org/jira/browse/AMQ-3624
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1213691 13f79535-47bb-0310-9956-ffa450edef68
2011-12-13 13:42:37 +00:00
Gary Tully 2bfd88e87d https://issues.apache.org/jira/browse/AMQ-3294 - disable this test as it causes hudson to hang. need to investigate reuse of send timeout for all sync operations and maxreconnect attempts on failover transport to fix up correctly.. one to revisit for case where exception other than security exception comes back or nothing in the case of max connections exceeded
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1213642 13f79535-47bb-0310-9956-ffa450edef68
2011-12-13 10:42:05 +00:00
Timothy A. Bish b6a3990d48 fix for: https://issues.apache.org/jira/browse/AMQ-3601
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1213298 13f79535-47bb-0310-9956-ffa450edef68
2011-12-12 16:27:09 +00:00
Bosanac Dejan 4c8ab44698 https://issues.apache.org/jira/browse/AMQ-3632 - staticBridge
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1213210 13f79535-47bb-0310-9956-ffa450edef68
2011-12-12 12:25:19 +00:00
Gary Tully 8d0cf31f84 resolve intermittent failure, wait for both of the conduit subs to register before test initiation. additional accessors to make validation possible
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1213209 13f79535-47bb-0310-9956-ffa450edef68
2011-12-12 12:22:11 +00:00
Gary Tully d4ccc50ea7 https://issues.apache.org/jira/browse/AMQ-3253 - rework to make recreation of temp destination more specific to use case, result is no advisories like https://issues.apache.org/jira/browse/AMQ-2571. This avoids the possibility of looping in a network. Additional test. Resolve race condition on destination advisories, a remove could overwrite an inflight add command. A copy is now in place for the remove
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1213208 13f79535-47bb-0310-9956-ffa450edef68
2011-12-12 12:19:43 +00:00
Gary Tully 9873e21aec https://issues.apache.org/jira/browse/AMQ-3628 - updated patch applied with thanks
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1212337 13f79535-47bb-0310-9956-ffa450edef68
2011-12-09 11:39:05 +00:00
Gary Tully 9df9d3e891 tidy up fix (exception was being lost) for URL: http://svn.apache.org/viewvc?rev=1209841&view=rev
Only stop transport for java.lang.SecurityException - as some tests rely on Connection continung after an exception from the broker
related to changes in support of fix for https://issues.apache.org/jira/browse/AMQ-3294 and https://issues.apache.org/jira/browse/AMQ-1928

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1211844 13f79535-47bb-0310-9956-ffa450edef68
2011-12-08 11:44:36 +00:00
Gary Tully 760c62934d https://issues.apache.org/jira/browse/AMQ-3622 - NPE in LastImageSubscriptionRecoveryPolicy. patch variant applied and nice test./bin/activemq console xbean:conf/limit.xml Thanks
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1211568 13f79535-47bb-0310-9956-ffa450edef68
2011-12-07 17:49:53 +00:00
Gary Tully 8bab1c1fb2 https://issues.apache.org/jira/browse/AMQ-3623 - Add DefaultTestAppender utility abstract class. patch applied with thanks
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1211533 13f79535-47bb-0310-9956-ffa450edef68
2011-12-07 16:56:50 +00:00
Torsten Mielke 2f72b71829 Added javadoc for BrokerService.start(boolean force) to discourage its use.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1210917 13f79535-47bb-0310-9956-ffa450edef68
2011-12-06 13:52:24 +00:00
Robert Davies 5bd4b19fab commit patch for https://issues.apache.org/jira/browse/AMQ-3618
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1210506 13f79535-47bb-0310-9956-ffa450edef68
2011-12-05 15:49:36 +00:00
Robert Davies 712303e6ec only do delayStop () for SecurityExceptions
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1210503 13f79535-47bb-0310-9956-ffa450edef68
2011-12-05 15:44:26 +00:00
Robert Davies da7f9962c6 Only stop transport for java.lang.SecurityException - as some tests rely on Connection continung after an exception from the broker
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1209841 13f79535-47bb-0310-9956-ffa450edef68
2011-12-03 07:15:12 +00:00
Robert Davies 3a71f8e33d Fix for https://issues.apache.org/jira/browse/AMQ-3294 and https://issues.apache.org/jira/browse/AMQ-1928
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1209700 13f79535-47bb-0310-9956-ffa450edef68
2011-12-02 21:34:14 +00:00
Gary Tully f260b17488 fix typo in last remove, oops sorry
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1209538 13f79535-47bb-0310-9956-ffa450edef68
2011-12-02 15:41:39 +00:00
Gary Tully 3a26442d92 extend the close wait for this test
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1209195 13f79535-47bb-0310-9956-ffa450edef68
2011-12-01 19:15:16 +00:00
Gary Tully a2fc5bc492 https://issues.apache.org/jira/browse/AMQ-3614 - Unable to generate unique id when range of ports are blocked - org.apache.activemq.util.IdGenerator. Patch applied with thanks, left the log at warn as unique ids are important and two simultaneous clients could use the same id with this fallback
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1209162 13f79535-47bb-0310-9956-ffa450edef68
2011-12-01 17:25:46 +00:00
James Strachan f1bbaec66b made the xmlpull parser an optional dependency in osgi-land. For some reason mavne bundle plugin doesn't figure this out; transitive dependences on optional dependences don't seem to get marked as optional
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1209117 13f79535-47bb-0310-9956-ffa450edef68
2011-12-01 15:20:32 +00:00
Gary Tully 6590d4b3d0 remove duplicate code removing advisories, handled cleanly in advisory broker already, additional load on destination map. Only on remove dest opts through, so impact is mostly small. better all the same. may lead to reduction in acces modes for the destination map
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1209058 13f79535-47bb-0310-9956-ffa450edef68
2011-12-01 12:48:51 +00:00
Gary Tully 3b7507f6b7 https://issues.apache.org/jira/browse/AMQ-2524 and https://issues.apache.org/jira/browse/AMQ-3092 - two competing fixes for the same underlying issue. Use a combination of the changes, disposed without the duplicate check for existance in the destinations. Removes one additional query on the destinations map
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1209046 13f79535-47bb-0310-9956-ffa450edef68
2011-12-01 11:54:47 +00:00
Gary Tully dad86e6891 ensure the reason is visible in a failure to accept connection due to oom
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1209045 13f79535-47bb-0310-9956-ffa450edef68
2011-12-01 11:54:13 +00:00
Gary Tully 3c3feb49a6 https://issues.apache.org/jira/browse/AMQ-3613 - rename rendezvous discovery to zeroconf
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1208660 13f79535-47bb-0310-9956-ffa450edef68
2011-11-30 18:31:22 +00:00
Gary Tully 599abc58bb https://issues.apache.org/jira/browse/AMQ-2730 - test to validate there is no implicit limit on reconnects due to the task runner exceeding its iterations, if the task is not complete it re queues it, so at least on trunk, the taskrunner issue is resolved
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1208377 13f79535-47bb-0310-9956-ffa450edef68
2011-11-30 10:58:21 +00:00
Gary Tully 44488a5bc3 https://issues.apache.org/jira/browse/AMQ-3607 - added test case and use of connectionFactory.setOptimizeAcknowledgeTimeOut, the test is breaking becauee of message discarding when the acks are not immediate, made some small mods to make the test work and fixed up the setter for connectionFactory.setOptimizeAcknowledgeTimeOut
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1208048 13f79535-47bb-0310-9956-ffa450edef68
2011-11-29 19:52:37 +00:00
Gary Tully c9414c4a6d https://issues.apache.org/jira/browse/AMQ-3611 - Revert the Oracle jdbc adapter to a variant of the default jdbc adapter in place of the one supporting blobs. added oracleBlobJDBCAdapter for backward compatibility and latest oracle adapter extends the default adapter so it no longer manipulates blobs directly, works fine with the latest ojdbc6 driver
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1207963 13f79535-47bb-0310-9956-ffa450edef68
2011-11-29 16:49:02 +00:00
Gary Tully 21541daf84 reduce duration
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1207715 13f79535-47bb-0310-9956-ffa450edef68
2011-11-29 00:11:02 +00:00
Gary Tully c70952723c reduce the duration of this tests
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1207713 13f79535-47bb-0310-9956-ffa450edef68
2011-11-29 00:07:23 +00:00
Gary Tully 8e0cc676d8 reduce the duration of this test
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1207699 13f79535-47bb-0310-9956-ffa450edef68
2011-11-28 23:31:58 +00:00
Gary Tully 395bf82f80 https://issues.apache.org/jira/browse/AMQ-2868 - fix issue with blocked transaction completion in highly concurrent systems. It was possible to miss an after completion callback
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1207693 13f79535-47bb-0310-9956-ffa450edef68
2011-11-28 23:20:07 +00:00
Gary Tully 6813691a3d https://issues.apache.org/jira/browse/AMQ-3609 - Turn inactivity monitor thread off by default, new default 0
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1207239 13f79535-47bb-0310-9956-ffa450edef68
2011-11-28 14:44:56 +00:00
Gary Tully 00fb101e2a https://issues.apache.org/jira/browse/AMQ-3454 - all the little performance test, non imperative
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1207231 13f79535-47bb-0310-9956-ffa450edef68
2011-11-28 14:37:15 +00:00
Gary Tully 4d17a70809 https://issues.apache.org/jira/browse/AMQ-3454 - remove copy of destinationMap in region getDestinationMap api, return a direct reference to the unerlying concurrent hash map, makes it more efficient to determine presence of a destination
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1207224 13f79535-47bb-0310-9956-ffa450edef68
2011-11-28 14:30:46 +00:00
Gary Tully 49718ed8a6 https://issues.apache.org/jira/browse/AMQ-3576 - disable auditNetworkProducers by default, composite dests and virtual topics that create duplicates independent of producers are trapped in error, for simple networking this should be enabled
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1205930 13f79535-47bb-0310-9956-ffa450edef68
2011-11-24 17:02:35 +00:00
Bosanac Dejan 332c35ca18 https://issues.apache.org/jira/browse/AMQ-3384 - destinationFilter config out of dynamically included destinations
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1205508 13f79535-47bb-0310-9956-ffa450edef68
2011-11-23 17:44:52 +00:00
Gary Tully 33edc9902e https://issues.apache.org/jira/browse/AMQ-3603 - STOMP 1.1 introduced the heartBeat header implemented by the inactivity monitor, would be nice to have this option for stomp 1.0. Implement support for ?transport.defaultHeartBeat=5000,0 with test
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1205011 13f79535-47bb-0310-9956-ffa450edef68
2011-11-22 14:20:04 +00:00
Gary Tully 721d623ff6 https://issues.apache.org/jira/browse/AMQ-3600 - test should not be run with individual ack, persist redelivery count mode
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1203773 13f79535-47bb-0310-9956-ffa450edef68
2011-11-18 18:03:25 +00:00
Timothy A. Bish ddb15afe05 Fix for NPE in test.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1203662 13f79535-47bb-0310-9956-ffa450edef68
2011-11-18 14:23:33 +00:00
Gary Tully 8311938134 https://issues.apache.org/jira/browse/AMQ-3600 - Failover reconnect bypasses DestinationPathSeparatorBroker generating invalid destinations. fix with test. the messagePull currently does not reference the destination but to future proof and for consistency it should be escaped
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1203213 13f79535-47bb-0310-9956-ffa450edef68
2011-11-17 15:10:32 +00:00
Gary Tully 49e704461c https://issues.apache.org/jira/browse/AMQ-3599 - JaasDualAuthenticationPlugin, java.net.BindException: Address already in use on shutdown with pending connectons. resolve with test
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1203176 13f79535-47bb-0310-9956-ffa450edef68
2011-11-17 12:49:32 +00:00
Gary Tully 3557361e86 https://issues.apache.org/jira/browse/AMQ-3596 - FilePendingMessageCursor memory list does not respect priority for non persistent messages. Fix with test. Reuse pendinglist from vm cursor for the file pending message cursor in memory list
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1202153 13f79535-47bb-0310-9956-ffa450edef68
2011-11-15 12:21:20 +00:00
Bosanac Dejan 1462fd234c https://issues.apache.org/jira/browse/AMQ-3168 - use boolean editor for most used broker service boolean properties
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1201666 13f79535-47bb-0310-9956-ffa450edef68
2011-11-14 11:15:02 +00:00
Bosanac Dejan c0c92595fd https://issues.apache.org/jira/browse/AMQ-3168 - use boolean editor for createConnector property, to avoid problems with schema validation
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1201662 13f79535-47bb-0310-9956-ffa450edef68
2011-11-14 10:50:47 +00:00
Timothy A. Bish 5b99f118a2 Adds an additional test case to verify that when doing request reply with two connections that ReplyTo values are prefixed with /remote-temp-topic and /remote-temp-queue to indicate that the connection receiving them is not the one that created them.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1197717 13f79535-47bb-0310-9956-ffa450edef68
2011-11-04 19:10:20 +00:00
Gary Tully 0018f4a3ad https://issues.apache.org/jira/browse/AMQ-3576 - implementation for network connectors, the store needs to be queried b/c messages from multiple producers are multiplexed by a network connector bridge. Additional boolean auditNetworkProducers on TransportConnector can disable the check if duplicates can be dealt with by the application layer. Additional test included.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1197203 13f79535-47bb-0310-9956-ffa450edef68
2011-11-03 16:23:29 +00:00
Gary Tully 2711ad1f3f https://issues.apache.org/jira/browse/AMQ-3576 - fix regression in network connector tests, the sequence id check is not valud for bridges that concentrate messages from multiple consumers. duplicate suppression for network connectors needs to be based on message ids
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1197072 13f79535-47bb-0310-9956-ffa450edef68
2011-11-03 11:53:31 +00:00
Gary Tully 5cf33b52c1 https://issues.apache.org/jira/browse/AMQ-3576 - only update audit sequence on valid message, apply test to isolated class where broker side timeout is absent
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1196804 13f79535-47bb-0310-9956-ffa450edef68
2011-11-02 21:17:41 +00:00
Bosanac Dejan aa8bc42fd4 https://issues.apache.org/jira/browse/AMQ-3576 - tidying up the test
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1196710 13f79535-47bb-0310-9956-ffa450edef68
2011-11-02 17:23:39 +00:00
Bosanac Dejan 70057cb9ce https://issues.apache.org/jira/browse/AMQ-3576 - producer exchange sync last seq id
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1196709 13f79535-47bb-0310-9956-ffa450edef68
2011-11-02 17:23:15 +00:00
Gary Tully 6ffbed9947 test to valudate soWriteTimeout on the client
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1196570 13f79535-47bb-0310-9956-ffa450edef68
2011-11-02 13:31:02 +00:00
Timothy A. Bish 4ab5e910cb Fix timing dependent assertion.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1195988 13f79535-47bb-0310-9956-ffa450edef68
2011-11-01 13:26:26 +00:00
Timothy A. Bish 419fde4457 Fix for: https://issues.apache.org/jira/browse/AMQ-3537
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1195708 13f79535-47bb-0310-9956-ffa450edef68
2011-10-31 22:34:16 +00:00
Timothy A. Bish 0b6bf7ec1b Fix for: https://issues.apache.org/jira/browse/AMQ-1853
Tests included.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1195615 13f79535-47bb-0310-9956-ffa450edef68
2011-10-31 18:54:19 +00:00
Timothy A. Bish 0a66b79332 additional fixes for: https://issues.apache.org/jira/browse/AMQ-3547
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1195278 13f79535-47bb-0310-9956-ffa450edef68
2011-10-30 23:27:52 +00:00
Timothy A. Bish 15f641634b fix for: https://issues.apache.org/jira/browse/AMQ-3547
Add an assertion to test that interrupted state is preserved.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1195046 13f79535-47bb-0310-9956-ffa450edef68
2011-10-29 21:44:27 +00:00
Timothy A. Bish 83fde0b2a0 fix for: https://issues.apache.org/jira/browse/AMQ-3547
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1195045 13f79535-47bb-0310-9956-ffa450edef68
2011-10-29 21:42:49 +00:00
Timothy A. Bish f0ed5d0c72 Fix a couple of tests that sleep for longer than necessary, use the Wait object when possible.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1190615 13f79535-47bb-0310-9956-ffa450edef68
2011-10-28 21:57:37 +00:00
Gary Tully 9ee2967220 https://issues.apache.org/jira/browse/AMQ-3519 - fix intermittent failure of org.apache.activemq.broker.RedeliveryRestartTest. inddividual ack marking delivery must be sent sync
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1190265 13f79535-47bb-0310-9956-ffa450edef68
2011-10-28 12:11:18 +00:00
Timothy A. Bish 8340decaf3 Apply patch for https://issues.apache.org/jira/browse/AMQ-3541
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1189980 13f79535-47bb-0310-9956-ffa450edef68
2011-10-27 19:58:42 +00:00
Hiram R. Chirino 0d01b16e25 Fixes AMQ-3570: Improve ActiveMQ's XSD to allow elements to appear in any order
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1189740 13f79535-47bb-0310-9956-ffa450edef68
2011-10-27 13:19:49 +00:00
Gary Tully cf33916c6e this test takes too long in hudson, reduce the amount of messages processed, quantity does not add much to the test
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1189734 13f79535-47bb-0310-9956-ffa450edef68
2011-10-27 13:03:02 +00:00
Gary Tully 6778a49eec https://issues.apache.org/jira/browse/AMQ-3568 - Consumer auto acking of duplicate message dispatch can lead to Unmatched acknowledge: and redelivery. Using individual ack in this case. Added a warn, as this sort of duplicate shoud be trapped by the store producerAudit, maxFailoverProducersToTrack may need an increase
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1189700 13f79535-47bb-0310-9956-ffa450edef68
2011-10-27 10:21:20 +00:00
Timothy A. Bish e6909d8970 Apply patch for: https://issues.apache.org/jira/browse/AMQ-3567
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1189370 13f79535-47bb-0310-9956-ffa450edef68
2011-10-26 18:36:52 +00:00
Timothy A. Bish 28e9cd7eee fix for https://issues.apache.org/jira/browse/AMQ-2526
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1188925 13f79535-47bb-0310-9956-ffa450edef68
2011-10-25 21:23:30 +00:00
Gary Tully 07eef8e293 https://issues.apache.org/jira/browse/AMQ-3563 - Update javadoc links to point to JDK 1.6 and JEE 1.5. Patch applied with thanks.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1188788 13f79535-47bb-0310-9956-ffa450edef68
2011-10-25 16:57:39 +00:00
Gary Tully 9ba8d2681f https://issues.apache.org/jira/browse/AMQ-3564 - new masterslave: discovery scheme for network connectors to master slave pairs, more intuitive configuration. Layers over static:failover:(a,b)?maxReconnectAttempts=0. Impl and test
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1188641 13f79535-47bb-0310-9956-ffa450edef68
2011-10-25 13:03:18 +00:00
Timothy A. Bish 0b1b6fa3ca Give this one just a bit more time to see if its just slow machines that cause it to fail.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1188146 13f79535-47bb-0310-9956-ffa450edef68
2011-10-24 14:07:29 +00:00
Timothy A. Bish 534a44fbd6 https://issues.apache.org/jira/browse/AMQ-3559
Fix for failing unit test.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1188145 13f79535-47bb-0310-9956-ffa450edef68
2011-10-24 13:37:31 +00:00
Timothy A. Bish 06611d9c19 Fix assertion error messages so that indicate an actual error.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1187577 13f79535-47bb-0310-9956-ffa450edef68
2011-10-21 22:18:28 +00:00
Timothy A. Bish c273cab44a fix for: https://issues.apache.org/jira/browse/AMQ-3559
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1187538 13f79535-47bb-0310-9956-ffa450edef68
2011-10-21 21:02:56 +00:00
Gary Tully 5b796cd8d6 https://issues.apache.org/jira/browse/AMQ-3558 - Allow the base network consumer priority to be configured on a networkConnector. Addition of consumerPriorityBase atribute to networkConnector configuration, additional test. This allows the base to be configured such that one network connector can have priority over another
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1187461 13f79535-47bb-0310-9956-ffa450edef68
2011-10-21 16:46:43 +00:00
Gary Tully 85edfb3425 https://issues.apache.org/jira/browse/AMQ-3533 - mKahaDB, allow the directory of a filtered destination to be specified, such that destination journals can be split across disks. Fixed with test
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1187280 13f79535-47bb-0310-9956-ffa450edef68
2011-10-21 10:15:26 +00:00
Gary Tully 8ce077800f https://issues.apache.org/jira/browse/AMQ-3551 - exclude networkConnectors from sendFailIfNoSpace on producer flow control, with test for topic and queue networks
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1186952 13f79535-47bb-0310-9956-ffa450edef68
2011-10-20 17:35:04 +00:00
Timothy A. Bish fa40250863 Fix for: https://issues.apache.org/jira/browse/AMQ-2240
URI options that are unmatched should result in an error 
to prevent subtle errors in configuration.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1186842 13f79535-47bb-0310-9956-ffa450edef68
2011-10-20 15:04:21 +00:00
Timothy A. Bish 4553ff18ef Remove fixed port usage and disable JMX since this test doesn't use it.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1186833 13f79535-47bb-0310-9956-ffa450edef68
2011-10-20 14:27:07 +00:00
Gary Tully 6d077dc7b4 https://issues.apache.org/jira/browse/AMQ-3331 - apply variant of patch with thanks.
Added boolean attribute, alwaysSyncSend to the network connector. This allows the
behaviour for persistent messages to be applied to non-persistent messages.
It does not make sense to have an alwaysAsync mode as this could lead to lost
persistent messages.
Also, I agree with the assment of the use of the responseRequired flag, it should
be based on the persistence attribute of the message, which it is now.
This is vital such that messages sent in transactions are not sent async.
Thanks for the great test case, made life easier.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1186813 13f79535-47bb-0310-9956-ffa450edef68
2011-10-20 13:56:17 +00:00
Gary Tully f4e0725420 https://issues.apache.org/jira/browse/AMQ-3542 - prevent failover reconnect till start is initiated, prevents connection establishment w/o a listener which ensures a bridge is already ready to handle a response and start a local bridge, useDedicatedTaskRunner=true can lead to this case
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1186654 13f79535-47bb-0310-9956-ffa450edef68
2011-10-20 07:59:05 +00:00
Gary Tully 1250163f39 https://issues.apache.org/jira/browse/AMQ-3481 - check for tryLock success before unlock
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1186539 13f79535-47bb-0310-9956-ffa450edef68
2011-10-19 22:26:07 +00:00
Timothy A. Bish 1fd39c991e Remove dependence on fixed port.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1186494 13f79535-47bb-0310-9956-ffa450edef68
2011-10-19 21:11:34 +00:00
Gary Tully 54ff0ce448 https://issues.apache.org/jira/browse/AMQ-3542 - remove duplicate bridge stop, could on occasion beat another thread to the stop and cause a deadlock, resulting in intermittent failure to restart a bridge
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1186258 13f79535-47bb-0310-9956-ffa450edef68
2011-10-19 15:09:59 +00:00
Bosanac Dejan 3c3b5bbd74 https://issues.apache.org/jira/browse/AMQ-3550 - local option for vritual topics
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1186095 13f79535-47bb-0310-9956-ffa450edef68
2011-10-19 11:13:19 +00:00
Timothy A. Bish 6c82480a10 test for: https://issues.apache.org/jira/browse/AMQ-2200
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1185792 13f79535-47bb-0310-9956-ffa450edef68
2011-10-18 18:47:44 +00:00
Gary Tully 174c40579a https://issues.apache.org/jira/browse/AMQ-3542 - further simplification of network bridge start, remove latch wait states, add duplex test variant
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1185765 13f79535-47bb-0310-9956-ffa450edef68
2011-10-18 17:31:27 +00:00
Timothy A. Bish 970a97ac5f Push enough data through the socket so that the socket close gets detected.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1185210 13f79535-47bb-0310-9956-ffa450edef68
2011-10-17 14:33:41 +00:00
Timothy A. Bish 6c4bcb3197 https://issues.apache.org/jira/browse/AMQ-3500
Don't remove the options, just get them each time.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1185129 13f79535-47bb-0310-9956-ffa450edef68
2011-10-17 12:44:55 +00:00
Bosanac Dejan 75e6f1981d TwoBrokerVirtualDestDinamicallyIncludedDestTest - test virtual topics over network of brokers setup
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1185097 13f79535-47bb-0310-9956-ffa450edef68
2011-10-17 10:35:29 +00:00
Timothy A. Bish b7f280817d https://issues.apache.org/jira/browse/AMQ-3500
fix a cut and paste oops

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1184866 13f79535-47bb-0310-9956-ffa450edef68
2011-10-16 16:54:18 +00:00
Timothy A. Bish 56272fab37 https://issues.apache.org/jira/browse/AMQ-3500
Only validate the params inside the domain of the producer or consumer.  

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1184834 13f79535-47bb-0310-9956-ffa450edef68
2011-10-16 14:28:42 +00:00
Timothy A. Bish 9ff350033f fix for: https://issues.apache.org/jira/browse/AMQ-3543
Unit test added.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1183495 13f79535-47bb-0310-9956-ffa450edef68
2011-10-14 20:52:35 +00:00
Timothy A. Bish baac9e7e9a fix for: https://issues.apache.org/jira/browse/AMQ-1132
Remove the dependency on the ActiveIO test.jar.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1183359 13f79535-47bb-0310-9956-ffa450edef68
2011-10-14 13:40:49 +00:00
Timothy A. Bish 6579d9eada apply patch for: https://issues.apache.org/jira/browse/AMQ-3536
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1183342 13f79535-47bb-0310-9956-ffa450edef68
2011-10-14 13:07:01 +00:00
Timothy A. Bish 88f60580e3 apply fix for: https://issues.apache.org/jira/browse/AMQ-3500
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1183143 13f79535-47bb-0310-9956-ffa450edef68
2011-10-13 22:28:47 +00:00
Gary Tully 4acd13243a https://issues.apache.org/jira/browse/AMQ-3542 - Using failover: with static discovery in a network connector to choose from a master/slave tuple leads to hangs and invalid states. issue with demand forward bridge reacting to failover transport interupt/resume leading to race conditions. race condition with tracking bridges and restarts. change default maxReconnectAttempts=0 to mean none, -1 for infinte. Default behavour is still infinite. To reference a master slave pair, use: static:(failover:(a,b)?maxReconnectAttempts=0)?useExponentialBackOff=false. see org.apache.activemq.network.FailoverStaticNetworkTest
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1183062 13f79535-47bb-0310-9956-ffa450edef68
2011-10-13 20:07:48 +00:00
Timothy A. Bish f33f32e892 fix for: https://issues.apache.org/jira/browse/AMQ-3481
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1182890 13f79535-47bb-0310-9956-ffa450edef68
2011-10-13 14:54:15 +00:00
Timothy A. Bish 3b381e7c15 https://issues.apache.org/jira/browse/AMQ-3481
Further refine this fix to address some test failures. 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1182049 13f79535-47bb-0310-9956-ffa450edef68
2011-10-11 19:39:45 +00:00
Gary Tully ab9bce6147 give consumer a little more time for slower hardware
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1181711 13f79535-47bb-0310-9956-ffa450edef68
2011-10-11 11:09:39 +00:00
Gary Tully 6468eba5e6 update openwire verison for 5.6 release, addition of security token in connection control
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1181219 13f79535-47bb-0310-9956-ffa450edef68
2011-10-10 20:27:21 +00:00
Gary Tully 9c9b85659c https://issues.apache.org/jira/browse/AMQ-3532 - expiry of offline durable subscription on activation can lead do duplicate expiry processing and negative pending cursor size, resolve duplicate cursor remove and contention with dispatch, additional test
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1181112 13f79535-47bb-0310-9956-ffa450edef68
2011-10-10 18:21:46 +00:00
Timothy A. Bish 3a806e98dc Test for: https://issues.apache.org/jira/browse/AMQ-3324
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1181022 13f79535-47bb-0310-9956-ffa450edef68
2011-10-10 15:31:09 +00:00
Gary Tully 2398a3a377 https://issues.apache.org/jira/browse/AMQ-3519 - fix regression in org.apache.activemq.bugs.AMQ2983Test, transacted ack needs to use async remove to ensure a concurrent dispatch does not preceed an ack
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1180884 13f79535-47bb-0310-9956-ffa450edef68
2011-10-10 11:47:09 +00:00
Timothy A. Bish 8cf318788d fix for: https://issues.apache.org/jira/browse/AMQ-3481
Issues arises when the StompTransport is sending an Ack back for Auto Ack 
mode in the same thread as the message was dispatched in.  If an incoming 
command beats the auto ack to onCommand in the activity monitor it will block
as the original thread is now waiting on the incoming command for the transport
lock.  Need to send back the Auto Acks in their own thread using a Task Runner
in the Stomp Transport so that the dispatch thread can complete and release
its lock on the transport.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1180070 13f79535-47bb-0310-9956-ffa450edef68
2011-10-07 15:22:31 +00:00
Timothy A. Bish 216f74e003 Give a little extra time for the Stomp frames to take effect.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1180059 13f79535-47bb-0310-9956-ffa450edef68
2011-10-07 14:43:53 +00:00
Gary Tully ab12a60a3a https://issues.apache.org/jira/browse/AMQ-3526 - JDBC persistence adapter, destination mbeans not visible on restart till producers or consumers reattach. query to find inactive destinations was checking the wrong table name, resolved with new test
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1179999 13f79535-47bb-0310-9956-ffa450edef68
2011-10-07 10:57:41 +00:00
Gary Tully 58e9c66201 https://issues.apache.org/jira/browse/AMQ-3523 - fix issue with related test, org.apache.activemq.transport.discovery.DiscoveryNetworkReconnectTest
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1179612 13f79535-47bb-0310-9956-ffa450edef68
2011-10-06 13:09:49 +00:00
Timothy A. Bish 6faa9c3546 fix for: https://issues.apache.org/jira/browse/AMQ-3524
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1179470 13f79535-47bb-0310-9956-ffa450edef68
2011-10-05 23:17:22 +00:00
Gary Tully f793fbd7e6 https://issues.apache.org/jira/browse/AMQ-3523 - NetworkConnector MBean unregistration can fail with a transport disconnect - leaving dangling mbean, fix and test
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1179355 13f79535-47bb-0310-9956-ffa450edef68
2011-10-05 18:10:08 +00:00
Jonathan Anstey 2f4d11f9b0 AMQ-3457 - check the connection id to make sure we don't delete someone else's temp dest
Reviewed by gtully



git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1179328 13f79535-47bb-0310-9956-ffa450edef68
2011-10-05 17:15:19 +00:00
Timothy A. Bish e6254c2f8a fix for: https://issues.apache.org/jira/browse/AMQ-3465
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1178398 13f79535-47bb-0310-9956-ffa450edef68
2011-10-03 12:43:51 +00:00
Timothy A. Bish 0890672e08 Add missing license header
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1177799 13f79535-47bb-0310-9956-ffa450edef68
2011-09-30 19:38:46 +00:00
Timothy A. Bish 633428c6e3 fix for: https://issues.apache.org/jira/browse/AMQ-3014
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1177797 13f79535-47bb-0310-9956-ffa450edef68
2011-09-30 19:35:28 +00:00
Gary Tully 601f54f0df https://issues.apache.org/jira/browse/AMQ-3519 - allign tests with last minute attribute name change
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1177621 13f79535-47bb-0310-9956-ffa450edef68
2011-09-30 12:21:53 +00:00
Gary Tully 2030097e01 https://issues.apache.org/jira/browse/AMQ-3519 - Allow JMSRedelivered flag to survive a restart. Add transactedIndividualAck flag to connection factory and rewriteOnRedelivery to KahaDBPersistenceAdapter. These combine to persist the redelivery status on a rollback
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1177619 13f79535-47bb-0310-9956-ffa450edef68
2011-09-30 11:59:44 +00:00
Timothy A. Bish 7d8ce02dee fix for: https://issues.apache.org/jira/browse/AMQ-3517
Adds tests for the backup option and cleans up some other the other tests.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1177437 13f79535-47bb-0310-9956-ffa450edef68
2011-09-29 21:42:29 +00:00
Timothy A. Bish 1878e951c6 Use a Wait condition instead of sleeps to detect completion.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1177411 13f79535-47bb-0310-9956-ffa450edef68
2011-09-29 19:45:21 +00:00
Timothy A. Bish ad76330eed https://issues.apache.org/jira/browse/AMQ-3516
Add fix along with a unit test to ensure it stays fixed.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1177345 13f79535-47bb-0310-9956-ffa450edef68
2011-09-29 16:02:49 +00:00
Timothy A. Bish 6d31ed72f0 Make the test work without relying on a sleep statement to get the results needed.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1177338 13f79535-47bb-0310-9956-ffa450edef68
2011-09-29 15:38:15 +00:00
Timothy A. Bish b6b69113b1 apply fixes for https://issues.apache.org/jira/browse/AMQ-3513
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1177088 13f79535-47bb-0310-9956-ffa450edef68
2011-09-28 22:07:21 +00:00
Timothy A. Bish 02f63c9782 fix for: https://issues.apache.org/jira/browse/AMQ-3515
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1177022 13f79535-47bb-0310-9956-ffa450edef68
2011-09-28 19:10:40 +00:00
Timothy A. Bish 3dbc9c9548 apply code cleanup patch from https://issues.apache.org/jira/browse/AMQ-3322
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1176580 13f79535-47bb-0310-9956-ffa450edef68
2011-09-27 19:59:07 +00:00
Timothy A. Bish d717a495c7 fix for: https://issues.apache.org/jira/browse/AMQ-3465
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1176393 13f79535-47bb-0310-9956-ffa450edef68
2011-09-27 14:13:16 +00:00
Timothy A. Bish 2a0b4893c6 apply patch for: https://issues.apache.org/jira/browse/AMQ-3509
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1175855 13f79535-47bb-0310-9956-ffa450edef68
2011-09-26 13:14:45 +00:00
Timothy A. Bish 8976a6b973 fix for: https://issues.apache.org/jira/browse/AMQ-3511
Log Stomp frames sent and received by the StompTransport under
org.apache.activemq.transport.stomp.StompIO when the trace option
is enabled.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1175047 13f79535-47bb-0310-9956-ffa450edef68
2011-09-23 22:04:20 +00:00
Timothy A. Bish fef66a6e98 fix for https://issues.apache.org/jira/browse/AMQ-3242
Make the max value actually be Short.MAX_VALUE

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1174954 13f79535-47bb-0310-9956-ffa450edef68
2011-09-23 18:58:55 +00:00
Timothy A. Bish 1453c53105 fix for: https://issues.apache.org/jira/browse/AMQ-3031
Don't use the scheduleAtFixedRate method in our scheduler as we
don't really have a need for real time task execution, just use
the fixed delay scheduler so that jobs don't stack up.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1174951 13f79535-47bb-0310-9956-ffa450edef68
2011-09-23 18:48:19 +00:00
Timothy A. Bish 2db7cbf436 Remove the dependency on the fixed 61616 port number
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1174734 13f79535-47bb-0310-9956-ffa450edef68
2011-09-23 13:13:33 +00:00
Timothy A. Bish d314b7f57d https://issues.apache.org/jira/browse/AMQ-3449
Add the setters/getters back for the ignore wireformat options.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1174097 13f79535-47bb-0310-9956-ffa450edef68
2011-09-22 12:45:07 +00:00
Gary Tully ad6b5e29db https://issues.apache.org/jira/browse/AMQ-3289 - updates to Blob/Oracle JDBCAdapter - applied patch from William McDonald with thanks
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1173605 13f79535-47bb-0310-9956-ffa450edef68
2011-09-21 12:45:48 +00:00
Gary Tully e6a9ae2f31 https://issues.apache.org/jira/browse/AMQ-3507 - Large number of expiring messages causing QueueSize to groww. have cursor delegate to the destination for expiry processing. additional test. This will also sort out the intermittent failure of this test.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1173583 13f79535-47bb-0310-9956-ffa450edef68
2011-09-21 12:09:30 +00:00
Timothy A. Bish e23afb3391 change for https://issues.apache.org/jira/browse/AMQ-3467
fix and issue created when the new changes were merged.




git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1173188 13f79535-47bb-0310-9956-ffa450edef68
2011-09-20 15:22:53 +00:00
Timothy A. Bish 5325cdb30b fixes for https://issues.apache.org/jira/browse/AMQ-3467
Clean up some code in MessageDatabase, add guards around logging to avoid big string ops when not
needed.  



git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1172640 13f79535-47bb-0310-9956-ffa450edef68
2011-09-19 14:23:02 +00:00
Gary Tully a36e618f71 https://issues.apache.org/jira/browse/AMQ-3501 - make use of the encoded string! and add some tests
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1172572 13f79535-47bb-0310-9956-ffa450edef68
2011-09-19 11:30:14 +00:00