961 Commits

Author SHA1 Message Date
gtully
83f519cd65 https://issues.apache.org/jira/browse/AMQ-2327 - fix regression in org.apache.activemq.network.NetworkBrokerDetachTest - need to conduit statically included durables when dynamicOnly=false (local networkSubs) 2013-10-01 16:05:01 +01:00
gtully
a80a1857d0 https://issues.apache.org/jira/browse/AMQ-2327 - fix regression in org.apache.activemq.usecases.TwoBrokerTopicSendReceiveLotsOfMessagesUsingTcpTest - statically included and dynaically included topic of same name. Need to conduit statically included (local networkSubs) 2013-10-01 15:21:21 +01:00
Dejan Bosanac
b8d5ca8383 https://issues.apache.org/jira/browse/AMQ-4758 - improve performance of pull consumers; more improvments; removed obsolete code and added extra check for dropped messages 2013-10-01 14:07:49 +02:00
Dejan Bosanac
2a5ad365d7 https://issues.apache.org/jira/browse/AMQ-4758 - improve performance of pull consumers 2013-10-01 12:22:19 +02:00
Hiram Chirino
21fe8cac7d Make the mKahaDB store agnostic to the nested persistence adapter type. 2013-09-27 04:26:17 -04:00
Timothy Bish
74dafd7f24 https://issues.apache.org/jira/browse/AMQ-4731
Just use a concurrent linked queue, makes the code much simpler and
doesn't hurt performance overall
2013-09-26 18:01:43 +01:00
Timothy Bish
8f7dbccf4c https://issues.apache.org/jira/browse/AMQ-4731
Initial fix for this issue.  Uses a separate collection to track the
creation time of the consumers, might want to test just using a
ConcurrentLinkedQueue since that will stay in creation or naturally
although the remove operations could cost more...removed debug logs.
2013-09-20 18:03:18 -04:00
Timothy Bish
2142045953 https://issues.apache.org/jira/browse/AMQ-4731
Initial fix for this issue.  Uses a separate collection to track the
creation time of the consumers, might want to test just using a
ConcurrentLinkedQueue since that will stay in creation or naturally
although the remove operations could cost more..
2013-09-20 16:50:20 -04:00
gtully
efaa351db7 https://issues.apache.org/jira/browse/AMQ-4365 - allow lease locker to be used by kahadb - remove deps on jdbc pa. LockableService now passes a reference to a locker so it can pull the brokerService, extracted some of the jdbc lock common stuff, additional test kahadb with jdbc lease 2013-09-20 15:33:24 +01:00
gtully
0f90695db7 https://issues.apache.org/jira/browse/AMQ-4729 - add lockableSupport to mKahaDb to isolate it from dynamically created filtered kahadb locks, nested locks are disabled when top level lock is in place. default to a sharedfile locker 2013-09-19 21:58:43 +01:00
gtully
29b90b5812 https://issues.apache.org/jira/browse/AMQ-4643 - have keepAlive task trap the new suppressreplyexception such that it can stay alive and renew a lease on resumption 2013-09-17 21:01:40 +01:00
gtully
dd91e8592e https://issues.apache.org/jira/browse/AMQ-4092 - resolve by removing dynamic property modification - JMSXGroupFirstForConsumer is now a message attribute with a property accessor 2013-09-17 11:03:57 +01:00
Dejan Bosanac
a69379d5fb https://issues.apache.org/jira/browse/AMQ-4621 - remove check for the inflight size, as ignoreIdleConsumers=true should do the work 2013-09-16 16:23:24 +02:00
Dejan Bosanac
269d44cfdd https://issues.apache.org/jira/browse/AMQ-4621 - return modified trace logging 2013-09-16 15:23:37 +02:00
Dejan Bosanac
25af8e62cc https://issues.apache.org/jira/browse/AMQ-4621 - some improvements to the AbortSlowAckConsumerStrategy 2013-09-16 15:18:29 +02:00
Timothy Bish
e1bbde7302 https://issues.apache.org/jira/browse/AMQ-4721
Upgrade to latest slf4j library and update many LOG statements to use
proper calls (no string concats).  Removes many uneeded isXXXEnabled
checks to clean up the code.
2013-09-13 14:53:41 -04:00
Timothy Bish
cdb7bb11ff https://issues.apache.org/jira/browse/AMQ-4621
Update the consumer / connection abort process such that when the
strategy is configured to abort the connection is only attempt to do so
once instead of once for every subscription in the map.  Also improve
logging to better indicate the subscription being aborted and the
destination that the subscription was on.
2013-09-12 15:10:25 -04:00
Timothy Bish
8f8aa0f5e2 https://issues.apache.org/jira/browse/AMQ-4621
Improve logging and configuration
2013-09-11 14:24:29 -04:00
Timothy Bish
77bcffc9b9 https://issues.apache.org/jira/browse/AMQ-4621
Additional work, adds an option to ignore network subscriptions by
default.  When the ignoreIdleConsumers setting is false and the abort
connection option is true this can cause the bridges to be torn down and
rebuilt for no reason.
2013-09-11 11:28:20 -04:00
Rob Davies
16c1627ca0 Fix for https://issues.apache.org/jira/browse/AMQ-4719 2013-09-11 09:21:06 +01:00
Hiram Chirino
9c75fe7b61 Fix for AMQ-4717: populateJMSXUserID is not setting the JMSXUserID property on the JMS message in JMX 2013-09-10 10:45:52 -04:00
Timothy Bish
272de3a146 https://issues.apache.org/jira/browse/AMQ-4621
some minor tweaks to the slow ack abort strategy, wasn't always kicking
in when it should have.
2013-09-09 17:48:12 -04:00
gtully
6c5732bc5c https://issues.apache.org/jira/browse/AMQ-2327 - resolve. key is not to conduit proxy/proxy consumers b/c the dependencies cannot be easily resolved without more network traffic on additions to demand subs. Maintaining the order of consumer advisories fixes duplicate suppression. thanks for the easymock test. while brittle it did help focus on checkpaths which was key 2013-09-06 22:46:09 +01:00
rajdavies
5515b9be3f Fix for https://issues.apache.org/jira/browse/AMQ-4714 2013-09-06 14:02:10 +01:00
rajdavies
0a5b14386f Fix for https://issues.apache.org/jira/browse/AMQ-4714 2013-09-06 13:46:43 +01:00
gtully
74b35bc5dd https://issues.apache.org/jira/browse/AMQ-4705 - add check for lock file exist and use error in place of warn if lock is lost 2013-09-03 21:24:09 +01:00
Dejan Bosanac
a3a22efb25 improving publishable address policy interface, so we can get the actual publish URI 2013-09-03 18:04:37 +02:00
Timothy Bish
8320e66b5d Fixes https://issues.apache.org/jira/browse/AMQ-4704 2013-09-03 11:50:52 -04:00
Dejan Bosanac
40af36e934 add ability to do port mapping when publishing connector uris; important in restricting environments 2013-09-03 17:07:13 +02:00
gtully
0525772190 https://issues.apache.org/jira/browse/AMQ-4709 - add support for <authorizationEntry .. read="*" ..> to match any group 2013-09-03 00:37:33 +01:00
gtully
3222767e79 https://issues.apache.org/jira/browse/AMQ-3779 - add perDestinationLogger attribute - logger for producer send of the form: org.apache.activemq.broker.util.LoggingBrokerPlugin.<type>.<name> 2013-09-03 00:32:22 +01:00
gtully
0525f88639 https://issues.apache.org/jira/browse/AMQ-4705 - implement keepAlive with a delegation to channel lock isValid 2013-09-03 00:30:48 +01:00
gtully
634a81898c https://issues.apache.org/jira/browse/AMQ-4682 - use spring.schemas for spring.xsd resolution - use brokerContext for configurationurl, support property PropertyPlaceholderConfigurer locations and system prop replacement, nested networkConnector elements - excludedDestinations,dynamicallyIncludedDestinations etc. lists and sets of destination 2013-09-03 00:28:46 +01:00
Robert Davies
f71e2fe21a Fix for https://issues.apache.org/jira/browse/AMQ-4697
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1518261 13f79535-47bb-0310-9956-ffa450edef68
2013-08-28 15:19:00 +00:00
Gary Tully
65ba623c96 https://issues.apache.org/jira/browse/AMQ-2902 - resolve intermittent test failure when stop ocurrs while start is in progress
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1518171 13f79535-47bb-0310-9956-ffa450edef68
2013-08-28 11:48:15 +00:00
Robert Davies
56070afa01 tidied up the javadocs for MessageBrokerView and added a test case for BrokerDestinationView
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1518145 13f79535-47bb-0310-9956-ffa450edef68
2013-08-28 10:21:12 +00:00
Gary Tully
8635a06e4a https://issues.apache.org/jira/browse/AMQ-3024 - guard against null from stomp tests, npe regression
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1518123 13f79535-47bb-0310-9956-ffa450edef68
2013-08-28 09:31:40 +00:00
Gary Tully
e8ea6cd95c https://issues.apache.org/jira/browse/AMQ-4682 - add support for mods and additions to destination policy - primitive attributes only
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1518009 13f79535-47bb-0310-9956-ffa450edef68
2013-08-27 22:02:07 +00:00
Gary Tully
8d480b451a https://issues.apache.org/jira/browse/AMQ-4682 - support updates to authorizationPlugin/map/authorizationMap
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1517794 13f79535-47bb-0310-9956-ffa450edef68
2013-08-27 11:48:34 +00:00
Robert Davies
8f4ebbb40e Added Interceptor to support
https://issues.apache.org/jira/browse/AMQ-4690

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1517222 13f79535-47bb-0310-9956-ffa450edef68
2013-08-25 06:19:56 +00:00
Timothy A. Bish
01704eece0 https://issues.apache.org/jira/browse/AMQ-4689
Allows for the persistence adapter to implement JobSchedulerStore and also allows for user set JobSchedulerStore to be used even when persitence is off on the broker.  

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1517084 13f79535-47bb-0310-9956-ffa450edef68
2013-08-23 22:47:09 +00:00
Timothy A. Bish
174fe15b30 fix for: https://issues.apache.org/jira/browse/AMQ-4676 and https://issues.apache.org/jira/browse/AMQ-4673
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1517052 13f79535-47bb-0310-9956-ffa450edef68
2013-08-23 21:27:27 +00:00
Timothy A. Bish
2d861dae65 fix for: https://issues.apache.org/jira/browse/AMQ-4683
Make scheduler job dispatching start more deterministic

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1516912 13f79535-47bb-0310-9956-ffa450edef68
2013-08-23 16:01:12 +00:00
Gary Tully
92860ae622 https://issues.apache.org/jira/browse/AMQ-4682 - implement virtualDestinationInterceptor runtime updates
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1516451 13f79535-47bb-0310-9956-ffa450edef68
2013-08-22 13:47:15 +00:00
Gary Tully
25a1dd071a https://issues.apache.org/jira/browse/AMQ-4682 - implement network connector modification, match, stop, apply restart
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1515461 13f79535-47bb-0310-9956-ffa450edef68
2013-08-19 15:18:55 +00:00
Gary Tully
3630a41fc9 https://issues.apache.org/jira/browse/AMQ-4682 - implement runtimeConfigurationPlugin that will track xml config and react to changes. simple verification via test that adds a new network connector on the fly
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1513871 13f79535-47bb-0310-9956-ffa450edef68
2013-08-14 13:23:36 +00:00
Gary Tully
0ba311f14b fix typo in logged message
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1511839 13f79535-47bb-0310-9956-ffa450edef68
2013-08-08 15:38:34 +00:00
Bosanac Dejan
a7533ba922 https://issues.apache.org/jira/browse/AMQ-4656 - first stab at improving keepDurableSubsActive feature, by not stoping/starting cursor on subscription (de)activating
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1511333 13f79535-47bb-0310-9956-ffa450edef68
2013-08-07 14:36:40 +00:00
Timothy A. Bish
45c399d810 fix for: https://issues.apache.org/jira/browse/AMQ-4671
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1511321 13f79535-47bb-0310-9956-ffa450edef68
2013-08-07 14:05:42 +00:00
Gary Tully
708be6d822 intermittent hang of test for https://issues.apache.org/jira/browse/AMQ-2021 showed concurrency flaw in https://issues.apache.org/jira/browse/AMQ-3236 - properties are only applied to the message copy that is deferred till needed
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1508819 13f79535-47bb-0310-9956-ffa450edef68
2013-07-31 11:50:06 +00:00