Commit Graph

497 Commits

Author SHA1 Message Date
Timothy Bish 7af7c0143f https://issues.apache.org/jira/browse/AMQ-5597
Clean up the durable subscription unsubscribe handling to be in line
with the AMQP JMS mapping spec and switch to the QPid 0.32-SNAPSHOT
build for now to allow us to track and other changes we might want to
feed back there before release.
2015-02-27 12:18:49 -05:00
gtully 0142c4dc89 https://issues.apache.org/jira/browse/AMQ-5614 - additional expiration attribute on dead letter strategy and tests 2015-02-25 14:32:43 +00:00
gtully be919fbc94 https://issues.apache.org/jira/browse/AMQ-4483 - rework to use destination option to indicate dlq, dlq strategy is typically not in place for dlq dests, option is set when a dlq is first used via region broker sendTodlq, fix and tests 2015-02-25 14:32:43 +00:00
gtully 85b9c81a3f https://issues.apache.org/jira/browse/AMQ-5229 - implement ability to pause/resume dispatch of message to all consumers of a queue 2015-02-23 21:41:33 +00:00
Robert Gemmell 1406d40ac3 AMQ-5608: dont NPE during authentication attempt if no users were defined for the SimpleAuthenticationPlugin
https://issues.apache.org/jira/browse/AMQ-5608
2015-02-23 17:42:17 +00:00
Dejan Bosanac 05c3112402 https://issues.apache.org/jira/browse/AMQ-5594 - virtual topics and wildcards 2015-02-18 18:29:20 +01:00
Timothy Bish 94937e855a https://issues.apache.org/jira/browse/AMQ-5589
Reduce the overall time to run the AMQP tests
2015-02-16 16:47:12 -05:00
Dejan Bosanac 1cab713864 https://issues.apache.org/jira/browse/AMQ-5585 - move messages on memory limit 2015-02-13 15:16:52 +01:00
gtully db084ef776 fix AMQ1936Test,AMQ2021Test timeouts - hitting unnecessary 1s wait on shutdown command completion 2015-02-13 12:01:50 +00:00
gtully b60bfbbeb4 Revert "rework https://issues.apache.org/jira/browse/AMQ-3684 and https://issues.apache.org/jira/browse/AMQ-4532 to avoid intermittent hangs, processing shutdown wile shutdown is in progress - AMQ1936Test and AMQ2021Test - using just TransportDisposedIOException to propagate exception response and start shutdown process and ignoring broker side for logging"
This reverts commit 8cf98a070f.

seems there are a bunch of network tests that don't conform with the new approach - back to the drawing board
2015-02-12 18:00:58 +00:00
gtully 8cf98a070f rework https://issues.apache.org/jira/browse/AMQ-3684 and https://issues.apache.org/jira/browse/AMQ-4532 to avoid intermittent hangs, processing shutdown wile shutdown is in progress - AMQ1936Test and AMQ2021Test - using just TransportDisposedIOException to propagate exception response and start shutdown process and ignoring broker side for logging 2015-02-11 13:37:32 +00:00
gtully 3155c625c6 https://issues.apache.org/jira/browse/AMQ-5567 - fix and test - issue was eager dispatch with concurrent sends, recovery and outcome delivery now assign a new sequence id to message additions which sorts sequence order in the xa case 2015-02-06 12:56:29 +00:00
gtully dc25f2a8f9 https://issues.apache.org/jira/browse/AMQ-5541 - support preemptive redelivery for non persistent case, fix and test 2015-01-27 16:43:35 +00:00
gtully 6c5dd2543e StoreDurableSubscriberCursor don't set its inner cursors' maxProducersToAudit correctly #57 - patch applied with thanks 2015-01-26 21:28:35 +00:00
gtully 6cebd2c79e https://issues.apache.org/jira/browse/AMQ-5513 - interaction with - https://issues.apache.org/jira/browse/AMQ-5068 - need to ensure broker cached messages state reflects delivery attempt - RedeliveryRestartWithExceptionTest regression 2015-01-26 12:13:55 +00:00
gtully a2c5c22ec5 https://issues.apache.org/jira/browse/AMQ-5513 - additional test for reconnect/rebalance case - indicate the absense of delivery information to the destination 2015-01-23 15:23:35 +00:00
gtully 981c0f20fa fix hang on org.apache.activemq.network.FailoverStaticNetworkTest - network connector vm creation clashing with broker stop 2015-01-23 11:27:10 +00:00
gtully 189a75afdc fix AMQ4221Test failure on low disk space - use warn level when resetting to available. Test checked log for error messages 2015-01-22 11:41:06 +00:00
Claus Ibsen 5c7985c695 AMQ-5523: Average message size attribute on statistics plugin should not have decimals 2015-01-16 09:29:52 +01:00
Claus Ibsen dbf2c28b96 AMQ-5521: Average message size attribute on destination mbean should not have decimals 2015-01-16 09:22:28 +01:00
gtully cf62d58ae7 https://issues.apache.org/jira/browse/AMQ-5515 - tidy up jetty deps - fix jetty maven coords 2015-01-12 22:58:07 +00:00
gtully 849987e5dd https://issues.apache.org/jira/browse/AMQ-5513 - remove inadvertent change of statement log level 2015-01-12 13:12:25 +00:00
gtully 8dbb48a23f https://issues.apache.org/jira/browse/AMQ-4107 - apply patch - resolved intermittent failure of TwoMulticastDiscoveryBrokerTopicSendReceiveTest 2015-01-12 12:00:42 +00:00
gtully dbb1d8b83d https://issues.apache.org/jira/browse/AMQ-5513 - have lastDeliveredSequence -1 indicate nothing was received, respect this value in queue sub remove and durable sub deactivate. 0 still constitutes no info - so old clients see same behaviour as before 2015-01-09 13:30:59 +00:00
Hadrian Zbarcea 8e0865d5d1 [AMQ-5505]. Add getUptimeMillis to the BrokerView MBean. This closes #56 2015-01-05 13:23:19 -05:00
Dejan Bosanac 9f53e2bcae adding missing licences 2014-12-29 12:25:04 +01:00
gtully e16815ad3b https://issues.apache.org/jira/browse/AMQ-5174 - apply patch from paulGale with thanks replace jdbc specific lease io handler with generic lease io handler - closesThis closes #53 2014-12-22 12:37:43 +00:00
gtully 13c207292f fix failing DbRestartJDBCQueueTest 2014-12-15 14:21:47 +00:00
gtully 2d9959a6f6 https://issues.apache.org/jira/browse/AMQ-5476 - ZeroPrefetchConsumerTest regression - fix default in connection factory and refactor prefetchExtension support - https://issues.apache.org/activemq/browse/AMQ-2560 2014-12-15 14:21:47 +00:00
gtully d25c52ccb2 https://issues.apache.org/jira/browse/AMQ-5483 - fix and test - assigned group counts are updated when lru map evicts a group assignment 2014-12-11 14:42:00 +00:00
Timothy Bish 164e303e21 https://issues.apache.org/jira/browse/AMQ-5473
Apply patch that allows for durable subs to migrate when links are
stolen.
2014-12-09 10:35:58 -05:00
gtully bc3587cfc9 fix failing RecoverExpiredMessagesTest - remove duplicate ref to secedualler task in jdbc pa inheritance and fix persistence adapter ref in test 2014-12-08 14:00:43 +00:00
gtully 60ad053486 https://issues.apache.org/jira/browse/AMQ-2719 - resolve possible skipped dispatch - https://issues.apache.org/jira/browse/AMQ-2106 - remove overload so that distribution order is not compromised when consumers are removed with a valid last delivered sequence. Additional test that uses consumer recreation to redistribute groups 2014-12-05 13:59:04 +00:00
gtully 74f530a641 https://issues.apache.org/jira/browse/AMQ-5457 - fix and test - we now peek first in redeliveredWaitingDispatch 2014-11-25 14:23:33 +00:00
Timothy Bish 7d136de422 https://issues.apache.org/jira/browse/AMQ-5421
Ensure concurrent access to the destinations state data does not cause
errors.
2014-11-04 16:04:29 -05:00
gtully 52e1a05aaa https://issues.apache.org/jira/browse/AMQ-5347 - variant of patch and additional tests applied, prefetch=0 test without restart exposed ordering bug with fix for https://issues.apache.org/jira/browse/AMQ-2719 2014-10-31 16:40:41 +00:00
Dejan Bosanac dffccb1c7d https://issues.apache.org/jira/browse/AMQ-5417 - use proper classloader in TaskRunnerFactory 2014-10-29 11:30:15 +01:00
gtully 33089f3fbb https://issues.apache.org/jira/browse/AMQ-5266 track cursor pending additions size in debug logging 2014-10-23 16:56:24 +01:00
gtully 8b8f630080 isolate cursor storeHasMessage logic into durable topic sub cursor b/c only durable sub cursors have selectors that won't match, otherwise we should always read a page if the store has messages 2014-10-21 23:23:15 +01:00
gtully 67ead201e1 https://issues.apache.org/jira/browse/AMQ-5266 https://issues.apache.org/jira/browse/AMQ-4485 - single dest test with low limit exposed ignored setbatch in kahadb when sequence was not found in the index due to acking - resolved and validated with test that verifies dlq is empty 2014-10-21 16:05:46 +01:00
Timothy Bish 3873ecfe5d https://issues.apache.org/jira/browse/AMQ-5396
Reviewed the patch and it looks good, I made a small change to prevent
logging in the case where no old context exists so we don't spam the
logs.
2014-10-20 19:06:21 -04:00
gtully 1d39f08c12 https://issues.apache.org/jira/browse/AMQ-5266 https://issues.apache.org/jira/browse/AMQ-4485 - fix warn logging from kahadb on set batch when message already consumed using seq from messageId, additional single dest test that hammers this case 2014-10-17 16:55:23 +01:00
gtully 4705f95bec https://issues.apache.org/jira/browse/AMQ-5266 https://issues.apache.org/jira/browse/AMQ-4485 - tidy up exception trace and async check, fix leveldb async test regressions 2014-10-17 11:25:47 +01:00
gtully 9c2b1d2572 https://issues.apache.org/jira/browse/AMQ-5266 https://issues.apache.org/jira/browse/AMQ-4485 - store has messages must be aware of pending also kahadb setBatch for async sends. additional tests and tidy up of cusror sync with store to reflect async/sync additions 2014-10-16 23:35:18 +01:00
gtully 243db1c289 rework npe avoidance in vmtransport stop to resolve thread leakage test failure 2014-10-16 23:35:18 +01:00
gtully 8216e7f4d5 https://issues.apache.org/jira/browse/AMQ-4930 - limit browse page in iterations in case cursor and store are out of sync - avoid a spin when store does not return messages 2014-10-16 23:35:17 +01:00
gtully 0cf7c0bc47 add trace logging to cursor page in 2014-10-09 22:16:54 +01:00
Timothy Bish 62c20ebdcf Apply fix and add test for:
https://issues.apache.org/jira/browse/AMQ-5385
2014-10-09 12:40:13 -04:00
gtully 97c127d2d4 https://issues.apache.org/jira/browse/AMQ-4485 - fix test regression with browse test - AMQ4595Test - reduce replay window when sync and asnyc cursor updates flip message order - concurrentStoreAndDispatch=true - https://issues.apache.org/jira/browse/AMQ-5266 - increse default audit depth to match async jobs for concurrent store 2014-10-09 13:47:31 +01:00
gtully a56996dd6c avoid npe on network bridge failure, dispose when not started on vm transport 2014-10-09 13:44:30 +01:00
gtully 140ce1bc8f https://issues.apache.org/jira/browse/AMQ-4485 - reenable test. concurrentStoreandDispatch case cannot be reconciled via setBatch, best we can do is trap duplicates from inflight messages as they occur. tagged async stores to support this. the revert of serialization with tx and non aysnc send brings perf back to where it was. https://issues.apache.org/jira/browse/AMQ-5266 2014-10-07 14:50:41 +01:00
gtully c1c82beb2d fix deadlock that blocks remote broker start in duplex case with durable sub recreation on restart - dynamicOnly=true works around 2014-10-07 14:50:41 +01:00
gtully 4ff5a3e48e improve trace logging on failure and tidy up future - try to nail down intermittent duplex bridge half start 2014-09-18 22:40:27 +01:00
gtully 357d491cbe https://issues.apache.org/jira/browse/AMQ-4705 - verify lock sanity on acquire so master cannot start and immediatly fail with a keepalive failure 2014-09-17 16:14:57 +01:00
gtully f19add11de add info log message for a queue purge event 2014-09-17 15:57:55 +01:00
gtully 5861d86ad3 https://issues.apache.org/jira/browse/AMQ-5266 - fix edge case with optimizedDispatch=true where a single message could be pending till the next page in event 2014-09-11 16:59:50 +01:00
gtully 26807cd452 https://issues.apache.org/jira/browse/AMQ-5274 - we now only check expiry on non inflight messages so there is on contention on ack with the periodic expriy check thread - related https://issues.apache.org/jira/browse/AMQ-2876 2014-09-11 16:13:43 +01:00
Dejan Bosanac 0b5231ada5 https://issues.apache.org/jira/browse/AMQ-5345 - improve ldap communication 2014-09-08 13:51:25 +02:00
gtully 8a37f97315 AMQ4677Test.testSendAndReceiveAllMessages - demoed the lack of reference increment for transacted send and the non completion of transacted futures in leveldb 2014-08-30 23:36:05 +01:00
gtully 54e2e3bef2 rework cursor store sync w.r.t to index order. resolve issues with skipped dispatch and duplicate dispatch. https://issues.apache.org/jira/browse/AMQ-4485 https://issues.apache.org/jira/browse/AMQ-5266 2014-08-30 00:51:21 +01:00
Timothy Bish b2afb8c969 https://issues.apache.org/jira/browse/AMQ-5337
Switch to LinkedHashMap with R/W locking for concurrent add / remove
protection
2014-08-29 15:52:23 -04:00
Timothy Bish 60bdfc061c https://issues.apache.org/jira/browse/AMQ-5315
Fix for possible NPE during start with immediate bridge failure.
2014-08-29 10:06:53 -04:00
Dejan Bosanac b9696ac80b https://issues.apache.org/jira/browse/AMQ-5333 - make xpath parser features configurable 2014-08-26 14:47:06 +02:00
Timothy Bish 00921f22ff Remove unused ConnectionControl handling. 2014-08-13 11:15:29 -04:00
gtully f158e7da67 https://issues.apache.org/jira/browse/AMQ-4930 - need to track paged in for queue count to match stat view - thanks MBeanTest and JmsQueueBrowserTest 2014-08-08 21:42:44 +01:00
Timothy Bish c391321d1b https://issues.apache.org/jira/browse/AMQ-5315
Fix for potential NPE on transport error.
2014-08-08 13:42:15 -04:00
Timothy Bish 4a2af3ab07 Add try/catch blocks to prevent client shutdown errors from preventing
Broker shutdown.
2014-08-08 12:34:38 -04:00
Timothy Bish 999385ea53 https://issues.apache.org/jira/browse/AMQ-5316
remove unused configuration entry to reduce confusion, can be added back
if ever needed to control additional logging.
2014-08-08 11:37:48 -04:00
gtully 7c2735d0f4 https://issues.apache.org/jira/browse/AMQ-5317 fix and test 2014-08-08 14:09:46 +01:00
gtully ab1e9c78ef https://issues.apache.org/jira/browse/AMQ-5311 - encode xaErrorCode in xaexception message 2014-08-07 13:42:10 +01:00
Torsten Mielke 5648482311 https://issues.apache.org/jira/browse/AMQ-5304 - applying groupClass to <tempDestinationAuthorizationEntry> 2014-08-07 11:08:38 +02:00
Torsten Mielke 98f707bd1e https://issues.apache.org/jira/browse/AMQ-5304 - still missing unit test case 2014-08-07 10:55:04 +02:00
gtully 41659725f4 https://issues.apache.org/jira/browse/AMQ-4930 - ensure we page in messages for browse/expire when destination stats are disabled via config 2014-08-06 15:21:19 +01:00
Dejan Bosanac c99e2d8372 https://issues.apache.org/jira/browse/AMQ-4719 - allowLinkStealing was not set/used properly by default on mqtt connector 2014-08-05 16:23:45 +02:00
Timothy Bish 4b0e3e57ba https://issues.apache.org/jira/browse/AMQ-5290
Add some utility methods that are useful for restoring past
subscriptions.
2014-07-30 12:00:38 -04:00
Timothy Bish f55edcfa25 https://issues.apache.org/jira/browse/AMQ-5187
Allow virtual destination to recover retained messages.
2014-07-29 17:20:25 -04:00
gtully 25e3c1b3c6 https://issues.apache.org/jira/browse/AMQ-5289 - add forwardCount to destinationStatistics - allow local consumption to be accounted with dequeueCount - forwardCount so forwarded messages are not accounted for num hops times 2014-07-25 11:48:20 +01:00
Timothy Bish d223ea979f https://issues.apache.org/jira/browse/AMQ-4818
added patch with addition of getter for link stealing enabled and a unit
test.
2014-07-22 17:53:39 -04:00
Timothy Bish b9fd189d56 https://issues.apache.org/jira/browse/AMQ-5253
Add accessors with the correctly spelled name and deprecate the old
ones.
2014-07-21 16:08:59 -04:00
Timothy Bish 4d4766e3a3 Fix small typo in the docs
This closes #35
2014-07-16 10:35:23 -04:00
gtully 3b5d89a78b https://issues.apache.org/jira/browse/AMQ-5277 - jdbc store make use of entryLocator on ack 2014-07-14 17:02:19 +01:00
gtully a9b8d98ed7 https://issues.apache.org/jira/browse/AMQ-5086 - init of broker got dropped after mutex wait - testWaitFor was failing 2014-07-14 17:02:18 +01:00
Timothy Bish 433912f79a https://issues.apache.org/jira/browse/AMQ-5271
Add an in-memory variant of the disk based JobScheduler store to allow
for an embedded broker to have scheduler support without needing to use
the disk based version.
2014-07-10 12:16:34 -04:00
gtully 0709c2cc1d https://issues.apache.org/jira/browse/AMQ-5213 - fix failing jmock test - resolve inconsistency in camel case attribute naming in a few mbeans 2014-07-10 13:51:08 +01:00
Jeff Genender bf1c57b33d AMQ-5265 - fix race condition for task 2014-07-09 16:43:30 +02:00
Timothy Bish ccf4b9f34f https://issues.apache.org/jira/browse/AMQ-5262
close connections when the connector is stopped.
2014-07-08 16:20:21 -04:00
Timothy Bish 74846bb2b4 https://issues.apache.org/jira/browse/AMQ-3758
Refactor the scheduler store into a more KahaDB style store that can
recover from various problems like missing journal files or corruption
as well as rebuild its index when needed.  Move the scheduler store into
a more configurable style that allows for users to plug in their own
implementations.  Store update from legacy versions is automatic.
2014-07-07 12:28:11 -04:00
Hadrian Zbarcea 6521549ec8 AMQ-5086. Fix the timeout arithmetic 2014-07-03 14:53:30 -04:00
Timothy Bish 106f759571 https://issues.apache.org/jira/browse/AMQ-5251
Synchronize method and remove old deprecated schedule method.
2014-06-28 10:21:34 -04:00
Timothy Bish cfce36197e https://issues.apache.org/jira/browse/AMQ-5086
Avoid a possible uneeded wait.
2014-06-09 16:21:00 -04:00
Timothy Bish 5016c4d4f2 https://issues.apache.org/jira/browse/AMQ-5086
Ensure that wait for started on vm transport factory actually waits for
start, currently it doesn't really check started or wait porperly.
2014-06-09 15:40:03 -04:00
gtully 27b3a7c344 https://issues.apache.org/jira/browse/AMQ-5212 - ensure uncontented access to concurrent destination map avoides deadlock, rerework https://issues.apache.org/jira/browse/AMQ-4952 to differenciate duplicates from send and recovered messages from the store. https://issues.apache.org/jira/browse/AMQ-3454 benefits from getDestinationMap(destination) to get direct access to the map to determine existance. Additional test 2014-06-09 12:32:33 +01:00
gtully 785faa06be disable autofail system.exit - it kills a surefire forked test run 2014-06-09 12:32:32 +01:00
Dejan Bosanac 845e62af76 https://issues.apache.org/jira/browse/AMQ-5218 - DestinationsPlugin 2014-06-09 12:48:02 +02:00
Timothy Bish 707940f1a6 https://issues.apache.org/jira/browse/AMQ-5214
Check for security error on responses and log a warning so there is a
record of the event
2014-06-05 16:16:01 -04:00
Timothy Bish 25f1fe8460 https://issues.apache.org/jira/browse/AMQ-5213
Adds a Log4JConfigViewMBean for use in configuring runtime logger
levels.
2014-06-05 14:39:56 -04:00
Timothy Bish 6c703ac6ee https://issues.apache.org/jira/browse/AMQ-5209
Add MessageId and original destination info to the advisory message
properties.
2014-06-04 13:30:42 -04:00
Dejan Bosanac 1591960887 fixing licenses 2014-06-03 14:03:28 +02:00
Dejan Bosanac 14fcd7cbea https://issues.apache.org/jira/browse/AMQ-5160 - make runtime configuration plugin work properly with destination filters 2014-06-03 13:26:43 +02:00
Dejan Bosanac aa2dfb60aa https://issues.apache.org/jira/browse/AMQ-5160 - fix XBeanConfigTest test 2014-06-02 17:50:28 +02:00
Dejan Bosanac 3ba129561c https://issues.apache.org/jira/browse/AMQ-5160 - start/stop wrapped policy 2014-06-02 13:22:25 +02:00
Dejan Bosanac 9d656731ab https://issues.apache.org/jira/browse/AMQ-4555 - fix regression that groupClass cannot be set on <cachedLDAPAuthorizationMap/> 2014-05-26 16:42:38 +02:00
Dhiraj Bokde 6c859676b3 Fixed AMQ-5160, fixed durable subscription retroactive recovery 2014-05-26 11:07:19 +02:00
Dhiraj Bokde 42ad1039cb Fixed AMQ-5160, restored previous DurableSubscription behaviour of only recovering messages when cursor is empty, retained messages are always recovered 2014-05-26 11:07:19 +02:00
Dhiraj Bokde c915b19a20 Fixed AMQ-5160, removed producer's retain property from retained messages 2014-05-26 11:07:19 +02:00
Dhiraj Bokde 78950ec596 Fixed AMQ-5160, changed DurableTopicSubscription to only recover retroactive messages for retroactive topics or consumers 2014-05-26 11:07:19 +02:00
Dhiraj Bokde 8947a09eaa Fixed AMQ-5160, force durable subscriptions to always recover retroactive messages 2014-05-26 11:07:19 +02:00
Dhiraj Bokde 5576dc5d74 Fixed AMQ-5160, fixed browse() to include messages from wrapped policy 2014-05-26 11:07:18 +02:00
Dhiraj Bokde a581d010aa Fixed AMQ-5160, Added RegionBroker.getConnectionContext(), made Topic.recoverRetroactiveMessages() public to force message recovery from MQTTProtocolConverter for duplicate subscriptions, added new tests for retained messages and JMX interoperability 2014-05-26 11:07:18 +02:00
Dhiraj Bokde bcb60a482c Partial fix for AMQ-5160, attempts to resolve retained messages using subscription recovery policy, but fails to resend retained messages for duplicate subscriptions 2014-05-26 11:07:18 +02:00
Timothy Bish 541ed8cf0c https://issues.apache.org/jira/browse/AMQ-5140
Add some checks to prevent any chance of an ArithmaticException because
of divide by zero.
2014-05-05 16:12:50 -04:00
Dhiraj Bokde 94b404d0ab Fixed AMQ-5160, allowed wildcard subscriptions for future destinations, added tests for wildcard authorization, fixed consumer and producer AdvisoryTopic names for composite destinations by replacing ',' with '&sbquo;' 2014-05-05 10:06:06 +02:00
Dhiraj Bokde a38a7c0093 Initial fix for AMQ-5160 to support subscription authorization for destination filters 2014-05-05 10:06:06 +02:00
gtully c5c1495330 https://issues.apache.org/jira/browse/AMQ-5136 - fix and test (thanks barlabanov) 2014-04-30 17:08:20 +01:00
gtully ad1f751a41 https://issues.apache.org/jira/browse/AMQ-5077 - reduce reader thread work when client uses async send; async store updates can now queue up to the destination memory limit b/c they don't block the send thread. Pending store writes are now tracked in memory usage. This allows a client to quickly provide a burst of messages to fill the destination cache bounded only by network bandwidth 2014-04-30 16:13:18 +01:00
Dejan Bosanac 4eb5097f22 https://issues.apache.org/jira/browse/AMQ-5165 - fix for destination stats name 2014-04-30 10:44:47 +02:00
Hadrian Zbarcea 3f32507f78 Use autocrlf consistently for line endings 2014-04-29 14:18:37 -04:00
Dejan Bosanac ec35588e56 https://issues.apache.org/jira/browse/AMQ-4182 - remove remaining use of finalize() 2014-04-24 16:06:01 +02:00
gtully 08bb172f3c https://issues.apache.org/jira/browse/AMQ-5077 - provide concurrentSend option to composite destinations such that fanout can occur in parallel, resulting in write batching. little perf test that shows a large improvement in send rate w/o concurrentStoreAndDispatch 2014-04-23 15:02:24 +01:00
Dejan Bosanac e947927511 https://issues.apache.org/jira/browse/AMQ-5149 - potential deadlock 2014-04-16 15:44:02 +02:00
Dejan Bosanac 7646526c0a https://issues.apache.org/jira/browse/AMQ-5141 - send messages to dlq using broker security context 2014-04-14 17:05:53 +02:00
Timothy Bish 307005ab4f https://issues.apache.org/jira/browse/AMQ-5138 2014-04-07 10:58:08 -04:00
Timothy Bish a554c7ca84 https://issues.apache.org/jira/browse/AMQ-5052
tone down noisy log
2014-03-31 18:42:37 -04:00
Timothy Bish bc326c8e57 https://issues.apache.org/jira/browse/AMQ-5122
tone down logging of warn to just exception message, full exception
logged as debug.
2014-03-31 18:34:58 -04:00
gtully c07514f570 https://issues.apache.org/jira/browse/AMQ-5119 - fix (pfox thanks for the test) the marshalled properties were being retained so a property removal was being ignored before the schedualed resend 2014-03-27 15:12:12 +00:00
artnaseef 29f34f4dab AMQ-5107: Do not resend messages while the broker is shutting down. Includes junit. 2014-03-27 08:07:59 -07:00
gtully 75eb814ca7 https://issues.apache.org/jira/browse/AMQ-5068 - don't rewrite durable subs as the message instance is shared 2014-03-26 11:50:13 +00:00
gtully 266d23ef79 revisit https://issues.apache.org/jira/browse/AMQ-3519 with more durable solution https://issues.apache.org/jira/browse/AMQ-5068 - JMSRedelivered header now persisted before dispatch so that it is a reliable indication of a possible duplicate delivery. The option is enabled via destination policy persistJMSRedelivered 2014-03-26 11:16:42 +00:00
gtully 9bf9e1c052 https://issues.apache.org/jira/browse/AMQ-5114 - force local removeInfo after connection controll consumer remove command so consumer is always removed from the broker, independent of the consumer state 2014-03-21 12:22:38 +00:00
Kevin Earls a3701fcb92 Fixe for AMQ-4977, removed dead code 2014-03-19 18:57:57 +01:00
gtully b136df177f https://issues.apache.org/jira/browse/AMQ-5089 - fix and test, respect client ack for topics and only decrement counters when ack is received 2014-03-19 15:33:44 +00:00
gtully 9c24716044 https://issues.apache.org/jira/browse/AMQ-4930 tracked hung org.apache.activemq.usecases.ExpiredMessagesWithNoConsumerTest#testExpiredMessagesWithNoConsumer - when using lower -Xmx than maven run - looping on browse due to no page when hasSpace fails. Browse picks up this state now 2014-03-12 16:51:22 +00:00
gtully 6aaf859d22 https://issues.apache.org/jira/browse/AMQ-4656 - fix regression for FilePendingDurableSubscriberMessageStoragePolicy 2014-03-11 15:18:46 +00:00
Claus Ibsen 37eb6b0c6e AMQ-4831: Use long value for average message size on borker (JMX) like min/max values also is. 2014-03-07 16:14:23 +01:00
gtully cfe099d1cc rework https://issues.apache.org/jira/browse/AMQ-3305 in the context of https://issues.apache.org/jira/browse/AMQ-4952 dlq processing of duplicates, also possible missed dispatch with interleaved xa completion and new messages - recovered transactions are now individually tracked by the store and replayed in the next batch, which negates the need to flush the cursor and avoids duplicates 2014-03-05 14:51:05 +00:00
gtully 69c0d399fb make perpared xa transactions visible in kahadb persistenceadapter view mbean 2014-03-03 13:55:27 +00:00
gtully e8818fafea https://issues.apache.org/jira/browse/AMQ-5080 - fix up rar transacted delivery and redelivery processing, xarecovery and transaction completion afer failover - using failover maxReconnectAttempts=0 to avoid blocking periodic recovery and negate replay of aborted transaction state 2014-03-03 13:22:30 +00:00
Dejan Bosanac c6fe94ec03 https://issues.apache.org/jira/browse/AMQ-5070 - broker blocked on shutdown 2014-02-21 11:22:11 +01:00
Hiram Chirino 93ca04468b Implements AMQ-5054: Display the number of active transactions and age of oldest transaction on a Connection's JMX info 2014-02-14 16:22:50 -05:00
Hiram Chirino 190a44bf25 Implements AMQ-5050: Populate a 'Host' header in the WireFormatInfo of the Openwire protocol to let multi-tenant proxies route connections. 2014-02-13 14:15:20 -05:00
Timothy Bish 4c38b03d14 https://issues.apache.org/jira/browse/AMQ-5035
Fix and test for variations in configuration settings that result in a
non-region broker as the AdvisoryBroker's next instance.
2014-02-10 18:14:41 -05:00
gtully 519d8f7db0 https://issues.apache.org/jira/browse/AMQ-5038 - close active sessions on deactivate to ensure consumption stops for an endpoint 2014-02-10 15:12:39 +00:00
Kevin Earls afded924ff Fix for AMQ-4899 2014-02-07 09:41:50 +01:00
Timothy Bish da3775302c https://issues.apache.org/jira/browse/AMQ-5011 2014-01-31 17:25:26 -05:00
Dejan Bosanac d4d985503e https://issues.apache.org/jira/browse/AMQ-4526 - prevent JMX restart if restartAllowed=false 2014-01-31 12:26:41 +01:00
Timothy Bish fde22a8496 https://issues.apache.org/jira/browse/AMQ-4754
Add connection counts to Broker mbean
2014-01-28 14:07:39 -05:00
Dejan Bosanac 713250f5f0 https://issues.apache.org/jira/browse/AMQ-4995 - more fixes 2014-01-28 16:08:53 +01:00
Dejan Bosanac 55da9bc821 https://issues.apache.org/jira/browse/AMQ-4995 - reapply destination interceptor after change 2014-01-28 14:53:18 +01:00
Timothy Bish f7cbe9fa17 https://issues.apache.org/jira/browse/AMQ-4970
Prevent multiple start / stop operations on a queue from having any
effect.
2014-01-20 10:43:44 -05:00
gtully cc47ab6d00 https://issues.apache.org/jira/browse/AMQ-4952 deal with jdbc store, cursor audit=false case, also relevant when cursor window is exceeded. Treating duplicate into pagedInMessages as an error, silently ignoring leads to trapped messages or deferred dispatch after a restart, revert change from https://issues.apache.org/jira/browse/AMQ-1957 2014-01-09 12:16:37 +00:00