Commit Graph

3277 Commits

Author SHA1 Message Date
Gary Tully d1e35e6c3a add trivial boolean selector test
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@959298 13f79535-47bb-0310-9956-ffa450edef68
2010-06-30 13:12:19 +00:00
Robert Davies 452ceae26e Name the BrokerService TaskRunner
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@959200 13f79535-47bb-0310-9956-ffa450edef68
2010-06-30 05:57:45 +00:00
Robert Davies d1b5029dc6 Remove the need to check if the store is empty when checking to enable cache
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@958330 13f79535-47bb-0310-9956-ffa450edef68
2010-06-27 06:07:02 +00:00
Robert Davies dd48ebea00 Use KahaDB (as now the default store)
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@958329 13f79535-47bb-0310-9956-ffa450edef68
2010-06-27 06:05:46 +00:00
Timothy A. Bish 9807ee3253 fix for: https://issues.apache.org/activemq/browse/AMQ-2098
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@958103 13f79535-47bb-0310-9956-ffa450edef68
2010-06-25 20:23:56 +00:00
Robert Davies ddb2c91c20 transaction performance enhancements
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@958009 13f79535-47bb-0310-9956-ffa450edef68
2010-06-25 15:45:47 +00:00
Gary Tully 39c536395a work around: javax.net.ssl.SSLHandshakeException: renegotiation is not allowed - http://java.sun.com/javase/javaseforbusiness/docs/TLSReadme.html for SslBrokerServiceTest with latest jdk security fixes
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@957916 13f79535-47bb-0310-9956-ffa450edef68
2010-06-25 12:23:07 +00:00
Gary Tully fb591e7b89 fix intermittent failure in JDBCNegativeQueueTest, sync store add and cursor add such that cursor is always in order w.r.t the store. Hense, when the cursor cache is exhausted, resuming from the store is just fine. Without the sync, moving from cache to store can result in duplicate messages, out of order messages and on occasion missing messages. disabling the cache resolved all of the above but kills performance. Syncing the sore add and cursor add is the correct solution, but it has an impact on concurrent transaction completion for a destination, paralell completion across destinations can still continue, so there is still some batching potential
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@957899 13f79535-47bb-0310-9956-ffa450edef68
2010-06-25 11:49:01 +00:00
Robert Davies 00879cf683 changes for https://issues.apache.org/activemq/browse/AMQ-2791
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@957881 13f79535-47bb-0310-9956-ffa450edef68
2010-06-25 10:28:17 +00:00
Bosanac Dejan eeacd65a2b https://issues.apache.org/activemq/browse/AMQ-2081 - anonymous access
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@957509 13f79535-47bb-0310-9956-ffa450edef68
2010-06-24 11:16:09 +00:00
Bosanac Dejan 1f063e8557 https://issues.apache.org/activemq/browse/AMQ-2790 - check connection to prevent NPEs
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@957213 13f79535-47bb-0310-9956-ffa450edef68
2010-06-23 14:23:51 +00:00
Bosanac Dejan ac77a047c0 https://issues.apache.org/activemq/browse/AMQ-2695 - counter fix
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@957210 13f79535-47bb-0310-9956-ffa450edef68
2010-06-23 14:11:19 +00:00
Bosanac Dejan d53609ff08 https://issues.apache.org/activemq/browse/AMQ-2695 - kahadb store directory location
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@957194 13f79535-47bb-0310-9956-ffa450edef68
2010-06-23 13:39:14 +00:00
Bosanac Dejan 9f417a2e5a https://issues.apache.org/activemq/browse/AMQ-2695 - additional fix for amq store
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@957181 13f79535-47bb-0310-9956-ffa450edef68
2010-06-23 13:06:19 +00:00
Bosanac Dejan 2aa2278fc2 https://issues.apache.org/activemq/browse/AMQ-2793 - KahaDB default dir
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@957154 13f79535-47bb-0310-9956-ffa450edef68
2010-06-23 11:00:43 +00:00
Robert Davies 7ad152bac8 Ensure executor constructed correctly
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@957005 13f79535-47bb-0310-9956-ffa450edef68
2010-06-22 20:08:12 +00:00
Robert Davies c14dc3a06f Fix for https://issues.apache.org/activemq/browse/AMQ-2790
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@956918 13f79535-47bb-0310-9956-ffa450edef68
2010-06-22 15:20:49 +00:00
Bosanac Dejan a8b0d39915 intermittent failures on slow machines
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@956570 13f79535-47bb-0310-9956-ffa450edef68
2010-06-21 13:14:06 +00:00
Robert Davies 69e3b6c8c8 Fix for https://issues.apache.org/activemq/browse/AMQ-2786
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@956481 13f79535-47bb-0310-9956-ffa450edef68
2010-06-21 07:57:32 +00:00
Gary Tully d55404445a give it more time to build up writes
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@955993 13f79535-47bb-0310-9956-ffa450edef68
2010-06-18 13:08:31 +00:00
Gary Tully e85dda9c64 have KahaDB lock work in vm, so master slave tests can work ok. preserver kaha behaiour in this regard as it makes testing simpler. fix npe on shutdown if start fails
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@955973 13f79535-47bb-0310-9956-ffa450edef68
2010-06-18 12:27:51 +00:00
Bosanac Dejan ae5300b190 https://issues.apache.org/activemq/browse/AMQ-2782 - removing temp destinations over the network
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@955621 13f79535-47bb-0310-9956-ffa450edef68
2010-06-17 14:56:23 +00:00
Bosanac Dejan 9703219972 https://issues.apache.org/activemq/browse/AMQ-2782 - test case
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@955505 13f79535-47bb-0310-9956-ffa450edef68
2010-06-17 08:33:37 +00:00
Robert Davies f42c91f43d Fix for https://issues.apache.org/activemq/browse/AMQ-2475
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@955504 13f79535-47bb-0310-9956-ffa450edef68
2010-06-17 08:24:26 +00:00
Robert Davies 1999d948bb handle Future correctly passed back from the store
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@955221 13f79535-47bb-0310-9956-ffa450edef68
2010-06-16 12:49:24 +00:00
Robert Davies ddf228227c Enable XBean property editors
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@955183 13f79535-47bb-0310-9956-ffa450edef68
2010-06-16 10:24:53 +00:00
Robert Davies 47181b7b07 Fix for https://issues.apache.org/activemq/browse/AMQ-2738
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@955179 13f79535-47bb-0310-9956-ffa450edef68
2010-06-16 10:17:06 +00:00
Robert Davies 37b7d9cfbd remove JDK 1.6 specific calls
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@955178 13f79535-47bb-0310-9956-ffa450edef68
2010-06-16 10:12:23 +00:00
Robert Davies 774a9daa4d fixed incorrect broker URL
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@955171 13f79535-47bb-0310-9956-ffa450edef68
2010-06-16 09:42:32 +00:00
Robert Davies e70308804f clear down async tasks on stop
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@955168 13f79535-47bb-0310-9956-ffa450edef68
2010-06-16 09:38:46 +00:00
Robert Davies 7a5abebea8 make concurrent store and dispatch with transactions optional
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@955149 13f79535-47bb-0310-9956-ffa450edef68
2010-06-16 07:40:33 +00:00
Robert Davies 27262c8463 Transactions dispatch and commit to the store asynchronously, though the commit only returns to the producer when they both complete for KahaDB
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@955039 13f79535-47bb-0310-9956-ffa450edef68
2010-06-15 20:33:41 +00:00
Gary Tully ad06a5f9c3 resolve https://issues.apache.org/activemq/browse/AMQ-2765 - rework fix for https://issues.apache.org/activemq/browse/AMQ-2772 - each consumer needs to indicate when interuption processing is complete. till there is a need to do other wise, the connection consumers (used by the RA managed connection) immediatly allow redelivery
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@954972 13f79535-47bb-0310-9956-ffa450edef68
2010-06-15 17:17:07 +00:00
Bosanac Dejan 370d56e300 https://issues.apache.org/activemq/browse/AMQ-2770 - durable subscription mbean
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@954893 13f79535-47bb-0310-9956-ffa450edef68
2010-06-15 14:06:43 +00:00
Robert Davies dc6dc7e540 updated performance tests
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@954604 13f79535-47bb-0310-9956-ffa450edef68
2010-06-14 19:35:17 +00:00
Robert Davies 794e62fbaa Fix for https://issues.apache.org/activemq/browse/AMQ-2777
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@954599 13f79535-47bb-0310-9956-ffa450edef68
2010-06-14 19:21:21 +00:00
Gary Tully 027d2e71b6 resolve https://issues.apache.org/activemq/browse/AMQ-2779 - add selectorAware option to a virtual topic such that only message matching some exisitng subscription selector are propagated to a subscription queue, this allows dynamic selector usage withough the build up of unmatched messages on a destination
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@954540 13f79535-47bb-0310-9956-ffa450edef68
2010-06-14 16:25:57 +00:00
Bosanac Dejan bc2b677c4d https://issues.apache.org/activemq/browse/AMQ-2695 - durable subs and selectors - test that verifies amq store
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@954412 13f79535-47bb-0310-9956-ffa450edef68
2010-06-14 11:20:40 +00:00
Bosanac Dejan d96c1cb7a3 https://issues.apache.org/activemq/browse/AMQ-2695 - durable subs and selectors - fix for kahadb
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@954406 13f79535-47bb-0310-9956-ffa450edef68
2010-06-14 10:34:54 +00:00
Gary Tully 6b18edc771 add test for https://issues.apache.org/activemq/browse/AMQ-2084 that works just fine
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@953739 13f79535-47bb-0310-9956-ffa450edef68
2010-06-11 15:48:46 +00:00
Bosanac Dejan 9444a7903e https://issues.apache.org/activemq/browse/AMQ-2769 - durable sub unsubscribe
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@953708 13f79535-47bb-0310-9956-ffa450edef68
2010-06-11 14:46:40 +00:00
Gary Tully e771b88479 resolve: https://issues.apache.org/activemq/browse/AMQ-2772 - patch applied with thanks and new test case created to protect the change
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@953696 13f79535-47bb-0310-9956-ffa450edef68
2010-06-11 13:40:49 +00:00
Bosanac Dejan 2b6f36dbfd first stab at resolving https://issues.apache.org/activemq/browse/AMQ-2695
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@953384 13f79535-47bb-0310-9956-ffa450edef68
2010-06-10 16:43:38 +00:00
Bosanac Dejan bb17d61516 https://issues.apache.org/activemq/browse/AMQ-2665 - additional fix
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@953382 13f79535-47bb-0310-9956-ffa450edef68
2010-06-10 16:39:27 +00:00
Bosanac Dejan 9c47f6b385 https://issues.apache.org/activemq/browse/AMQ-2665 - durable activation and predefined topics
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@952976 13f79535-47bb-0310-9956-ffa450edef68
2010-06-09 12:22:52 +00:00
Bosanac Dejan bf61bebd79 cleaning up AMQ2413Test
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@952962 13f79535-47bb-0310-9956-ffa450edef68
2010-06-09 11:14:10 +00:00
Bosanac Dejan 9fcf16eaab https://issues.apache.org/activemq/browse/AMQ-2663 - keepDurableSubsActive=false reactivation
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@952946 13f79535-47bb-0310-9956-ffa450edef68
2010-06-09 10:31:49 +00:00
Bosanac Dejan 121ecb5599 https://issues.apache.org/activemq/browse/AMQ-2767 - proxyToLocalBroker <proxyConnector> property
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@952642 13f79535-47bb-0310-9956-ffa450edef68
2010-06-08 12:58:28 +00:00
Bosanac Dejan 99ef19a43d https://issues.apache.org/activemq/browse/AMQ-2753 - additional test
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@951067 13f79535-47bb-0310-9956-ffa450edef68
2010-06-03 16:51:40 +00:00
Gary Tully 3c8df79eca add test to veriry loadbalance across network, effect of prefetch on vm client vs nework consumer, allowed prefetch to be configured via xml property (ie string in schema) for xml config
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@950515 13f79535-47bb-0310-9956-ffa450edef68
2010-06-02 12:08:58 +00:00
Gary Tully 3271401883 resolve durable restart test regressions with kahaDB as default store, the next message sequence id could get out of sync for a durable sub when drained and reused, fix for https://issues.apache.org/activemq/browse/AMQ-2755
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@950171 13f79535-47bb-0310-9956-ffa450edef68
2010-06-01 17:28:21 +00:00
Gary Tully 7f0ced9402 resolve regression in FailoverTransactionTest following change to fix resolve https://issues.apache.org/activemq/browse/AMQ-2751, fix needs to be conditional on delayed delivery otherwise it can effect async transacted redelivery on failover
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@949789 13f79535-47bb-0310-9956-ffa450edef68
2010-05-31 16:12:06 +00:00
Gary Tully 72015ca681 resolve https://issues.apache.org/activemq/browse/AMQ-2754 - fix issue with conduit sub removal
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@949742 13f79535-47bb-0310-9956-ffa450edef68
2010-05-31 13:44:17 +00:00
Gary Tully ecf068e23b first cut at resolution to: https://issues.apache.org/activemq/browse/AMQ-2753 - add priority network consumer dispatch policy that will ignore duplicates such that there can be redundancy in the network with the addition of suppressDuplicateTopicSubscriptions attribute on a network bridge
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@948911 13f79535-47bb-0310-9956-ffa450edef68
2010-05-27 17:02:41 +00:00
Gary Tully b50ede668d resolve https://issues.apache.org/activemq/browse/AMQ-2752 - allow timestamp broker plugin to optinally modify network messages, processNetworkMessages attribute
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@948858 13f79535-47bb-0310-9956-ffa450edef68
2010-05-27 15:22:43 +00:00
Gary Tully ae7df9fcaa help in diagnosis of https://issues.apache.org/activemq/browse/AMQ-2749 - provide log message when waiting for space to free up
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@948489 13f79535-47bb-0310-9956-ffa450edef68
2010-05-26 16:29:38 +00:00
Gary Tully 18adfefabe resolve https://issues.apache.org/activemq/browse/AMQ-2751 - duplicate suppression over eager with listener, session.recover from a message listener when default delayed redelivery is in place
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@948463 13f79535-47bb-0310-9956-ffa450edef68
2010-05-26 14:52:20 +00:00
Gary Tully 33f4190343 resolve regression in ThreeBrokerVirtualTopicNetworkTest - asnyc tasks need to use destination in key as id is not uniqueue with virtual topics. Also, on a failed cancle, we must wait for the write to compete so the ack/remove does not lag the write leaving an outstanding message. consequence of fixes for https://issues.apache.org/activemq/browse/AMQ-2620 and
https://issues.apache.org/activemq/browse/AMQ-2568

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@948209 13f79535-47bb-0310-9956-ffa450edef68
2010-05-25 21:20:40 +00:00
Bosanac Dejan aace7c6937 https://issues.apache.org/activemq/browse/AMQ-1464 - fanout regression
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@947757 13f79535-47bb-0310-9956-ffa450edef68
2010-05-24 18:43:39 +00:00
Gary Tully 35593638f5 resolve ConnectorXBeanConfigTest, broker service needs to null more impls at shutdown to allow restart to find new impls of scheudaler etc. consequence of fixes for https://issues.apache.org/activemq/browse/AMQ-2620 and
https://issues.apache.org/activemq/browse/AMQ-2568

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@947671 13f79535-47bb-0310-9956-ffa450edef68
2010-05-24 15:36:14 +00:00
Gary Tully e1389a6acc allow journal write batching, resolve global transaction lock and journal lock, let writes accumulate on the datafileappender rather than at the store, also tie transaction completion and after commit processing together with a callback rather than with a global lock so that concurrent commits can batch their writes - rework of fix for https://issues.apache.org/activemq/browse/AMQ-2594
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@947657 13f79535-47bb-0310-9956-ffa450edef68
2010-05-24 14:48:55 +00:00
Hiram R. Chirino da0490b501 Fix for failing case in XARecoveryBrokerTest related to https://issues.apache.org/activemq/browse/AMQ-2620
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@947653 13f79535-47bb-0310-9956-ffa450edef68
2010-05-24 14:32:21 +00:00
Gary Tully c92fe9992b make perf test num producers configurable via command line to allow easy comparison, make test use transacted sends
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@947638 13f79535-47bb-0310-9956-ffa450edef68
2010-05-24 13:28:51 +00:00
Gary Tully 10a976674e possibly resolve https://issues.apache.org/activemq/browse/AMQ-2564 - add test and fix issue with slave replication effecting response correlator when message is queued waiting for space, the id can get out of sync, causing a missed reply to the orignal producer, which would result in a hang
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@946974 13f79535-47bb-0310-9956-ffa450edef68
2010-05-21 11:40:27 +00:00
Gary Tully 4386e118a1 remove deps on 1.6 constructor, no point making 1.6 a requirement for this little feature
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@946964 13f79535-47bb-0310-9956-ffa450edef68
2010-05-21 10:08:22 +00:00
Robert Davies e2a383690c added transacted topic test
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@946725 13f79535-47bb-0310-9956-ffa450edef68
2010-05-20 17:39:09 +00:00
Robert Davies cd6f4f5650 Fix null pointer exception in doStop()
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@946681 13f79535-47bb-0310-9956-ffa450edef68
2010-05-20 16:06:48 +00:00
Robert Davies 1a5ad284ed fixes for https://issues.apache.org/activemq/browse/AMQ-2620 and
https://issues.apache.org/activemq/browse/AMQ-2568

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@946600 13f79535-47bb-0310-9956-ffa450edef68
2010-05-20 12:02:10 +00:00
Gary Tully 1b6d397aab https://issues.apache.org/activemq/browse/AMQ-378 - add AbortSlowConsumerStrategy destination policy that will abort consumers that are repeatildy slow or slow for a defined period. Slowness is a product of the prefetch and message production rate.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@946138 13f79535-47bb-0310-9956-ffa450edef68
2010-05-19 11:56:52 +00:00
Gary Tully 50daa35a32 resolve failure of org.apache.activemq.store.jdbc.JDBCStoreOrderTest - async ack when in a transaction and transaction store message store proxy missing async impl, belt and braces, fix async ack and add sync imple to proxy - following async changes from http://svn.apache.org/viewvc?rev=945102&view=rev
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@946135 13f79535-47bb-0310-9956-ffa450edef68
2010-05-19 11:48:38 +00:00
Gary Tully 3713a3bdeb resolve https://issues.apache.org/activemq/browse/AMQ-2737 - add the two new files, oops
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@945709 13f79535-47bb-0310-9956-ffa450edef68
2010-05-18 15:45:07 +00:00
Gary Tully 21891008c5 resolve https://issues.apache.org/activemq/browse/AMQ-2737 - have nio work with soWritetTimeout filter
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@945692 13f79535-47bb-0310-9956-ffa450edef68
2010-05-18 15:20:33 +00:00
Robert Davies 5405ec8c49 Explicitly set the PersistenceAdapterFactory
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@945600 13f79535-47bb-0310-9956-ffa450edef68
2010-05-18 11:52:23 +00:00
Bosanac Dejan 8cf566b4ca assert that reconnecting durable sub on a remote broker works
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@945594 13f79535-47bb-0310-9956-ffa450edef68
2010-05-18 11:32:22 +00:00
Robert Davies b09ed031aa removeTopicTask fixed
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@945495 13f79535-47bb-0310-9956-ffa450edef68
2010-05-18 04:55:30 +00:00
Bosanac Dejan 0d05af6614 https://issues.apache.org/activemq/browse/AMQ-2456 - JaasDualAuthentcationPlugin/Broker
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@945227 13f79535-47bb-0310-9956-ffa450edef68
2010-05-17 16:04:23 +00:00
Robert Davies ea843782b3 added support for concurrent dispatch and store of persistent messages in KahaDB
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@945102 13f79535-47bb-0310-9956-ffa450edef68
2010-05-17 11:53:28 +00:00
Bosanac Dejan eb6fec879f https://issues.apache.org/activemq/browse/AMQ-2667 - make fileserver jetty neutral
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@944278 13f79535-47bb-0310-9956-ffa450edef68
2010-05-14 14:19:14 +00:00
Bosanac Dejan af159dd82b https://issues.apache.org/activemq/browse/AMQ-2713 - delete blob message files from server
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@944167 13f79535-47bb-0310-9956-ffa450edef68
2010-05-14 09:21:42 +00:00
Gary Tully dee584b99e make keepAlive optional for inactivity monitor, useKeepAlive=false option, such that it can be used to abort slow consumers
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@944163 13f79535-47bb-0310-9956-ffa450edef68
2010-05-14 09:08:07 +00:00
Bosanac Dejan 41a1842d8c https://issues.apache.org/activemq/browse/AMQ-2732 - more test refactorings
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@943934 13f79535-47bb-0310-9956-ffa450edef68
2010-05-13 16:47:53 +00:00
Bosanac Dejan 3af93f1898 https://issues.apache.org/activemq/browse/AMQ-2732 - ftp blob permission denied
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@943916 13f79535-47bb-0310-9956-ffa450edef68
2010-05-13 15:38:03 +00:00
Bosanac Dejan a34c80858e https://issues.apache.org/activemq/browse/AMQ-2732 - ftp blob permission denied
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@943915 13f79535-47bb-0310-9956-ffa450edef68
2010-05-13 15:37:35 +00:00
Gary Tully c909e965c7 fix assertion on discarded count
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@943877 13f79535-47bb-0310-9956-ffa450edef68
2010-05-13 13:10:49 +00:00
Gary Tully 429869d034 a trivial lrucache test to validate resize is not crazy
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@943861 13f79535-47bb-0310-9956-ffa450edef68
2010-05-13 10:13:21 +00:00
Bosanac Dejan 3a6a56c633 https://issues.apache.org/activemq/browse/AMQ-2729 - failover uri query parsing
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@943860 13f79535-47bb-0310-9956-ffa450edef68
2010-05-13 10:09:44 +00:00
Gary Tully c3a64a8eb3 add little test to validate load balancing in a simple network
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@943856 13f79535-47bb-0310-9956-ffa450edef68
2010-05-13 09:40:36 +00:00
Gary Tully 0e1d63269d make tests more resiliant to running on slower/loaded machines
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@943091 13f79535-47bb-0310-9956-ffa450edef68
2010-05-11 11:50:22 +00:00
Gary Tully 4a2b796acc fix assertion, thanks Darek
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@943085 13f79535-47bb-0310-9956-ffa450edef68
2010-05-11 11:19:48 +00:00
Gary Tully 41c2a9c469 add test for prosperity
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@942715 13f79535-47bb-0310-9956-ffa450edef68
2010-05-10 12:01:35 +00:00
Bosanac Dejan 4e8143711a https://issues.apache.org/activemq/browse/AMQ-2706 - request-reply over network
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@942131 13f79535-47bb-0310-9956-ffa450edef68
2010-05-07 15:48:53 +00:00
Gary Tully aa3110e26c add simple test for localport uri notation in a connection factory: http://activemq.apache.org/how-do-i-define-a-local-address-and-local-port-for-tcp-or-ssl.html
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@942025 13f79535-47bb-0310-9956-ffa450edef68
2010-05-07 08:03:49 +00:00
Gary Tully 79d303d802 some maven future proofing - resolve warn about pom property references
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@941712 13f79535-47bb-0310-9956-ffa450edef68
2010-05-06 13:09:16 +00:00
Gary Tully 591e55ffce resolve https://issues.apache.org/activemq/browse/AMQ-2720 - ensure kahaDB getDestinations returns only durable topic destinations and add test case for duplicate messages in a network after restart
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@941281 13f79535-47bb-0310-9956-ffa450edef68
2010-05-05 13:37:13 +00:00
Bosanac Dejan a3344e61a9 https://issues.apache.org/activemq/browse/AMQ-2719 - order of redelivered messages
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@941174 13f79535-47bb-0310-9956-ffa450edef68
2010-05-05 07:09:37 +00:00
Gary Tully 9b7ce0e490 add setDecreaseNetworkConsumerPriority and send another message to try and find problem, still good
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@939682 13f79535-47bb-0310-9956-ffa450edef68
2010-04-30 14:16:33 +00:00
Gary Tully 14f7c669ec add additional brokers to form a ring of 3
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@939327 13f79535-47bb-0310-9956-ffa450edef68
2010-04-29 14:35:13 +00:00
Gary Tully 3340371bdd test case that validates network with virtual topics and broker restart
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@939318 13f79535-47bb-0310-9956-ffa450edef68
2010-04-29 14:19:51 +00:00
Gary Tully fe89b0264b validation test for https://issues.apache.org/activemq/browse/AMQ-2716, delete of reply queue
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@939249 13f79535-47bb-0310-9956-ffa450edef68
2010-04-29 10:10:28 +00:00
Gary Tully c4d8bc47a0 tidy up vm url handling, fix failover and ssl context: resolve https://issues.apache.org/activemq/browse/AMQ-2715 and add test for same, improve logging around network connector
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@938998 13f79535-47bb-0310-9956-ffa450edef68
2010-04-28 16:12:29 +00:00
Bosanac Dejan 80fd502dcd https://issues.apache.org/activemq/browse/AMQ-2323 - make test JMX independent
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@938823 13f79535-47bb-0310-9956-ffa450edef68
2010-04-28 08:59:46 +00:00
Bosanac Dejan 4b6c80277a https://issues.apache.org/activemq/browse/AMQ-2636 - adding missing diff serv names
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@938461 13f79535-47bb-0310-9956-ffa450edef68
2010-04-27 14:10:44 +00:00
Bosanac Dejan 5280808865 https://issues.apache.org/activemq/browse/AMQ-2183 - composite destinations and master/slave
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@938353 13f79535-47bb-0310-9956-ffa450edef68
2010-04-27 08:22:59 +00:00
Bosanac Dejan e0d7906605 moving a test to activemq-spring
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@938343 13f79535-47bb-0310-9956-ffa450edef68
2010-04-27 07:48:49 +00:00
Bosanac Dejan 093c901329 https://issues.apache.org/activemq/browse/AMQ-2705 - broker version in jmx and web console
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@937334 13f79535-47bb-0310-9956-ffa450edef68
2010-04-23 15:27:36 +00:00
Gary Tully 36cc71d077 add some more detailed logging
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@937308 13f79535-47bb-0310-9956-ffa450edef68
2010-04-23 14:12:03 +00:00
Robert Davies 9524835224 Apply patch for https://issues.apache.org/activemq/browse/AMQ-2636
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@937272 13f79535-47bb-0310-9956-ffa450edef68
2010-04-23 12:46:41 +00:00
Robert Davies 9740fb21a6 Apply fixECNBits patch for https://issues.apache.org/activemq/browse/AMQ-2636
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@937265 13f79535-47bb-0310-9956-ffa450edef68
2010-04-23 12:32:40 +00:00
Bosanac Dejan f8b0c22d0f https://issues.apache.org/activemq/browse/AMQ-2323 - dupliactes with composite destinations
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@936811 13f79535-47bb-0310-9956-ffa450edef68
2010-04-22 12:25:16 +00:00
Gary Tully 956c3e0df2 resolve hang in purge if message count stats are off and log a warning.. tidy up broker service waitForStarted logic which caused AMQ2102 test to block.. still issue with master/slave sync with AMQ2102
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@936798 13f79535-47bb-0310-9956-ffa450edef68
2010-04-22 12:01:15 +00:00
Gary Tully eb983f7c08 resolve https://issues.apache.org/activemq/browse/AMQ-2704 - add message audit to topic sub so that a regular sub can behave like store backed subscriptions which already suppress duplicates. Dup ocurrs from ring network topology where there are two equal and valid routes for a message, see test case
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@936390 13f79535-47bb-0310-9956-ffa450edef68
2010-04-21 16:45:30 +00:00
Gary Tully 6a73c40c18 resolve https://issues.apache.org/activemq/browse/AMQ-2651 - modified patch applied with thanks, did not change the default as there are a bunch of tests and user applications that depend on the current default
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@935954 13f79535-47bb-0310-9956-ffa450edef68
2010-04-20 15:13:18 +00:00
Bosanac Dejan 76de7c05e6 https://issues.apache.org/activemq/browse/AMQ-2702 - introducing activemq-spring module
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@935952 13f79535-47bb-0310-9956-ffa450edef68
2010-04-20 15:05:29 +00:00
Bosanac Dejan bb0aed0425 GenerateJDBCStatements - eliminate compiler warnings
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@935638 13f79535-47bb-0310-9956-ffa450edef68
2010-04-19 15:58:11 +00:00
Bosanac Dejan 358b522b8d Some improvements for org.apache.activemq.ra.JmsXARollback2CxTransactionTest test as it fails in hudson
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@935501 13f79535-47bb-0310-9956-ffa450edef68
2010-04-19 09:54:19 +00:00
Bosanac Dejan 789789f06b https://issues.apache.org/activemq/browse/AMQ-2697 - policies for temp destinations
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@934961 13f79535-47bb-0310-9956-ffa450edef68
2010-04-16 15:27:54 +00:00
Bosanac Dejan db9533b631 NetworkBrokerDetachTest refactoring
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@934871 13f79535-47bb-0310-9956-ffa450edef68
2010-04-16 13:52:21 +00:00
Bosanac Dejan fab6ba187d JmsSchedulerTest give it more time to handle slow machines and add some debugging
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@934839 13f79535-47bb-0310-9956-ffa450edef68
2010-04-16 12:14:52 +00:00
Bosanac Dejan 952d036856 https://issues.apache.org/activemq/browse/AMQ-2696 - last broker sequence id and durable subscribers
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@934408 13f79535-47bb-0310-9956-ffa450edef68
2010-04-15 13:52:06 +00:00
Gary Tully a0d2282a41 resolve https://issues.apache.org/activemq/browse/AMQ-2668 - implement destination PolicyEntry storeUsageHighWaterMark to allow rough store usage split across destinations. an individual dest can use a 70% high watermark leaving the default 100% for a DLQ, so that it is not blocked on a store limit
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@934352 13f79535-47bb-0310-9956-ffa450edef68
2010-04-15 10:04:55 +00:00
Bosanac Dejan e037e069bd https://issues.apache.org/activemq/browse/AMQ-2448 - increasing failure margin
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@933256 13f79535-47bb-0310-9956-ffa450edef68
2010-04-12 14:44:14 +00:00
Gary Tully 9e54516aba resolve https://issues.apache.org/activemq/browse/AMQ-2693 - loaded machine with slow thread creation can delay interruption processing past next dispatch which can be problematic. prefetch=1 will workaround
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@933240 13f79535-47bb-0310-9956-ffa450edef68
2010-04-12 14:03:18 +00:00
Bosanac Dejan fc52e42636 AMQ2102Test improvements
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@933190 13f79535-47bb-0310-9956-ffa450edef68
2010-04-12 10:56:23 +00:00
Bosanac Dejan 80a7ec59b4 https://issues.apache.org/activemq/browse/AMQ-2448 - thread leak when network trying to connect to unavailable broker
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@932403 13f79535-47bb-0310-9956-ffa450edef68
2010-04-09 13:31:36 +00:00
Gary Tully 05f82a9b6d resolve https://issues.apache.org/activemq/browse/AMQ-2691 - ensure suppressed durable subs are acked so that message can be removed and not recovered at a later date. Tidy up network bridge creation so that durables are supported by default and allow dynamicOnly to determine if durables are auto bridged. Avoid duplicate mbeans for durable subs on restart and allow active to reflect status of a sub
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@932342 13f79535-47bb-0310-9956-ffa450edef68
2010-04-09 10:36:00 +00:00
Bosanac Dejan ce8f83acf1 https://issues.apache.org/activemq/browse/AMQ-2448 - adding test case
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@931216 13f79535-47bb-0310-9956-ffa450edef68
2010-04-06 16:37:26 +00:00
Bosanac Dejan b53e4b545a https://issues.apache.org/activemq/browse/AMQ-2684 - encoding for web sockets and stomp
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@931089 13f79535-47bb-0310-9956-ffa450edef68
2010-04-06 11:04:12 +00:00
Bosanac Dejan 684f5dfef1 https://issues.apache.org/activemq/browse/AMQ-2684 - encoding for web sockets and stomp
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@931047 13f79535-47bb-0310-9956-ffa450edef68
2010-04-06 08:19:18 +00:00
Bosanac Dejan 3336a22ff9 https://issues.apache.org/activemq/browse/AMQ-2681 - adding license header
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@930212 13f79535-47bb-0310-9956-ffa450edef68
2010-04-02 09:45:15 +00:00
Bosanac Dejan d22e841db9 https://issues.apache.org/activemq/browse/AMQ-2681 - typo fixed and generate jdbc statements class
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@930206 13f79535-47bb-0310-9956-ffa450edef68
2010-04-02 09:38:46 +00:00
Gary Tully 4eafcccf62 resolve https://issues.apache.org/activemq/browse/AMQ-2556 - resolve leaks with XA_RDONLY - prepare needs to cleanup the transaction state, both on the broker and on the client connection/session/failover state
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@930135 13f79535-47bb-0310-9956-ffa450edef68
2010-04-01 23:25:20 +00:00
David Jencks c22ea7fab0 ACTIVEMQ-2384 remove hard dependency on spring
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@930041 13f79535-47bb-0310-9956-ffa450edef68
2010-04-01 16:56:13 +00:00
Bosanac Dejan fd65b8201a https://issues.apache.org/activemq/browse/AMQ-2681 - findMessageByIdStatement
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@929918 13f79535-47bb-0310-9956-ffa450edef68
2010-04-01 10:56:26 +00:00
Gary Tully 9822d58d04 resolve https://issues.apache.org/activemq/browse/AMQ-2384 - not exactly the patch but allowing the introspector to work, which is more generic with some tests, thanks phil for the impetus on this
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@929618 13f79535-47bb-0310-9956-ffa450edef68
2010-03-31 16:54:49 +00:00
Gary Tully 2dd5b7737b resolve https://issues.apache.org/activemq/browse/AMQ-2670 - revert XA connection manager, using out of band recovery via JMS api is a workaround for jboss pending RAR based auto recovery or enlistment, comments in the jira with the relevant config
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@929145 13f79535-47bb-0310-9956-ffa450edef68
2010-03-30 14:02:40 +00:00
Bosanac Dejan 99d51265ff http://issues.apache.org/activemq/browse/AMQ-2507 - use commons logging
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@929094 13f79535-47bb-0310-9956-ffa450edef68
2010-03-30 11:48:02 +00:00
Bosanac Dejan 73338477ad https://issues.apache.org/activemq/browse/AMQ-2669 - jmx slave attribute for shared filesystem (jdbc) MS configurations
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@927324 13f79535-47bb-0310-9956-ffa450edef68
2010-03-25 10:07:53 +00:00
Gary Tully ff006954d8 add additional test class : https://issues.apache.org/activemq/browse/AMQ-2622
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@927066 13f79535-47bb-0310-9956-ffa450edef68
2010-03-24 14:10:59 +00:00
Gary Tully e9f30febec make ObjectMessage.copy aware of setObjectMessageSerializationDefered so that copy on dispatch can operate on message dispatch fields but message serialization is still avoided - resolve: https://issues.apache.org/activemq/browse/AMQ-2622
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@927054 13f79535-47bb-0310-9956-ffa450edef68
2010-03-24 13:51:00 +00:00
Gary Tully 363a1cf599 resolve issue with roll over and cron parser, hudson builds in different TZ has repeated faiure on trunk, getNext may still need some work
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@926646 13f79535-47bb-0310-9956-ffa450edef68
2010-03-23 16:20:40 +00:00
Robert Davies c9addfb50e remove Log messages from BrokerInfo to so JmsAppender works
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@926165 13f79535-47bb-0310-9956-ffa450edef68
2010-03-22 16:34:49 +00:00
Robert Davies dfeecb4519 Applied updated patch for https://issues.apache.org/activemq/browse/AMQ-2636
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@926152 13f79535-47bb-0310-9956-ffa450edef68
2010-03-22 16:09:44 +00:00
Robert Davies 475eedc7a6 Fix order in which scheduler is used in the broker
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@925351 13f79535-47bb-0310-9956-ffa450edef68
2010-03-19 17:41:13 +00:00
Robert Davies cc40251451 make sure scheduling works with transactions
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@925221 13f79535-47bb-0310-9956-ffa450edef68
2010-03-19 14:08:07 +00:00
Robert Davies efd6bda979 default updateClusterClients = false - to ensure JUnit tests pass - which rely on a defined failover:// list
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@925035 13f79535-47bb-0310-9956-ffa450edef68
2010-03-18 23:00:03 +00:00
Gary Tully d914548559 resolve https://issues.apache.org/activemq/browse/AMQ-2656 xa=true in the environment will ensure an XACOnnectionFactory is created
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@924972 13f79535-47bb-0310-9956-ffa450edef68
2010-03-18 20:02:13 +00:00
Bosanac Dejan 1cec28cf27 https://issues.apache.org/activemq/browse/AMQ-2594 - proper init of broker and store seq
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@924752 13f79535-47bb-0310-9956-ffa450edef68
2010-03-18 13:05:43 +00:00
Bosanac Dejan 229043b7d9 cleaning log4j.properties
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@924709 13f79535-47bb-0310-9956-ffa450edef68
2010-03-18 11:11:22 +00:00
Robert Davies e75affa660 Fix for https://issues.apache.org/activemq/browse/AMQ-2646
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@924661 13f79535-47bb-0310-9956-ffa450edef68
2010-03-18 07:21:12 +00:00
Bosanac Dejan af65ba7242 https://issues.apache.org/activemq/browse/AMQ-2654 - subscription info space character
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@924353 13f79535-47bb-0310-9956-ffa450edef68
2010-03-17 16:25:02 +00:00