947 Commits

Author SHA1 Message Date
Christopher L. Shannon (cshannon)
ccf56875b0 NO-JIRA - Update spring schemas and missing license files 2019-03-15 07:24:31 -04:00
gtully
2d394b383c AMQ-7167 - ensure remote IP is visible in acceptor error messages from the transport connector - test and fix 2019-03-13 10:21:19 +00:00
gtully
a000a73431 no jira - init throwable cause to identify error on shutdown 2019-03-13 10:14:06 +00:00
Alan Protasio
87467dc61e AMQ-7159 - Adding a new attribute on PersistenceAdapterViewMBean to show information about Storage write/read latency 2019-03-06 11:41:08 -08:00
Christopher L. Shannon (cshannon)
7fdad3a73d AMQ-7151 - Remove dependency on Guava from activemq-broker
Guava is supposed to only be used for the leveldb store and as a test
    dependency elsewhere but there is one spot it is used in activemq-broker for
    filtering collections. With Java 8 this can be easily rewritten to avoid the use of Guava.

    This commit is based on the patch submitted by Filip Hrisafov
2019-02-18 07:49:47 -05:00
Christopher L. Shannon (cshannon)
daea192eef AMQ-7085 - Properly start TempUsage inside Queue start
This fix allows temp usage changes to the broker temp usage to propagate
properly to a Queue's temp usage settings

Patch applied with thanks to David Sitsky
2019-01-17 07:58:36 -05:00
hkesler
5c23dd53ad AMQ7135 : do a purge before deleting the destination
(cherry picked from commit 9f513f88781667df1a2a4b0a85153059dc097295)
2019-01-14 13:44:52 -03:30
jgoodyear
4a21edc8d5 [AMQ-7126] Improvement to perf of 5266Test 2019-01-07 21:22:34 -03:30
gtully
8cc0c5ad6c AMQ-7106 - fix pending stop support by avoiding sync through single shared status var - fix and test 2018-11-21 10:23:13 +00:00
gtully
9cb680c0ba AMQ-7102 - don't track objectNames that have not been registered due to suppressMBean filter, fix and test 2018-11-15 17:45:18 +00:00
gtully
bc8c78cd32 AMQ-7009 - apply fix to memorymessagestore setBatch with thanks to Nezih BEN FREDJ for test and suggestion 2018-11-14 14:21:27 +00:00
gtully
d2b0affedb AMQ-7094 - track the objectName with an annotated mbean such that the jmx audit log event can extract that target of an mbean operation, fix and test 2018-11-08 12:10:01 +00:00
gtully
f2cde24a62 AMQ-7088 - fix deadlock on remove add interaction from mqtt virtual topic sub use case 2018-11-01 10:11:08 +00:00
gtully
bf8eb08aca AMQ-7086 - make kahadb gc/cleanup on shutdown optional to trade availability over disk usage for fast failover 2018-10-31 14:29:05 +00:00
gtully
9dd751149f AMQ-7079 AMQ-7077 AMQ-6421 - check for consumers that have been destroyed 2018-10-18 16:49:29 +01:00
gtully
4dee173962 AMQ-7077 AMQ-6421 - tie queue consumer slow flag detection to abort slow consumer policy, fire advisory when set. 2018-10-17 11:04:47 +01:00
Christopher L. Shannon (cshannon)
3ac3a420a1 AMQ-7071 - Mark previously dispatched messages as redelivered if
connection for durable topic subscription is improperly closed leading
to a lastDeliveredSequenceId as unknown
2018-10-12 08:35:37 -04:00
gtully
5246151288 AMQ-7062 - have redelivery plugin ignore messages detected as duplicates 2018-09-26 11:22:59 +01:00
gtully
cae66f5d37 AMQ-6086 - variant with broker.schedulerSupport=true; same fix with additional test 2018-09-25 16:29:24 +01:00
gtully
cdbddcafa2 AMQ-7057 - support transport connector warnOnRemoteClose to suppress eof warnings on loadbalance or health check socket ping 2018-09-20 14:58:34 +01:00
Christopher L. Shannon (cshannon)
69fad2a135 Add support for hostname verification 2018-08-31 06:39:49 -04:00
gtully
54c56a0573 AMQ-7037 - add sslContext attribute to networkConnector, allow broker or jvm defaults to be overridden 2018-08-20 16:40:26 +01:00
gtully
50d27e7e54 AMQ-7035 - use NonCachedMessageEvaluationContext in place of MessageEvaluationContext to avoid unnecessary reference count management and subsequent leaks. Rework AMQ-6465 with additional JMX related tests 2018-08-15 16:21:57 +01:00
gtully
bdfa3394ad AMQ-7030 - trap exceptions on future.get, fix and test 2018-08-02 14:45:31 +01:00
giliva
5b1412ddfd Avoid overflow errors - see KAFKA-4290
Add test for overflow values

Bind test sockets to free ports
2018-07-27 08:32:36 -04:00
Christopher L. Shannon (cshannon)
b79fcd0a76 AMQ-7017 - Prevent ArithmeticException in ProducerBrokerExchange
Check for zero to prevent divide by zero error inside
getPercentageBlocked() method

Thank you to Matthew Stratton for the patch
2018-07-27 07:40:49 -04:00
gtully
0b76d3a0ea AMQ-7021 - add unsynchronised accessors to destination map for usage with rw lock from abstract region; allow concurrent read of the destination map 2018-07-26 10:42:10 +01:00
gtully
c29d7477d0 no jira - fix warn formatting error 2018-07-05 11:54:22 +01:00
gtully
83514ef799 AMQ-7001 - ensure cursor pending cached id list is pruned of futures that end in an exception, fix and test 2018-07-03 21:18:36 +01:00
Jeff Genender
76490a2c7f AMQ-7002 - Change jobid identifier to messageid format 2018-06-27 10:29:40 -06:00
gtully
e0aa091d9e AMQ-7002 - ensure uniqueue jobids, fix and test via patch from Jamie goodyear applied with thanks 2018-06-27 14:14:44 +01:00
gtully
57a6f2373e AMQ-6854 - ensure non null return in the event on no space to page in 2018-06-13 13:10:52 +01:00
gtully
1ebf186279 AMQ-3405 - rework fix to use original destination strategy which may be different from the default shared strategy. new test 2018-06-07 11:38:42 +01:00
gtully
6d14e4e85b AMQ-6979 - fix test regression, avoid gc during shutdown such that the error check on the logging remains valid 2018-05-31 13:44:01 +01:00
gtully
cdb38b3275 AMQ-6979 - use scheduler as trigger task - do heavy lifting via the task runner executor, take care to trap errors to keep scheduler timer alive AMQ-5129 2018-05-30 22:03:50 +01:00
gtully
026c6f4403 AMQ-6967 - ensure there are some messages paged in for periodic expiry check if non are in memory 2018-05-21 14:26:45 +01:00
gtully
01384c714d AMQ-6707 - fix destination filter delegate param, refactor-auto-gen method; jees 2018-05-18 14:44:05 +01:00
gtully
2eff835ee2 AMQ-6703 - fix regression in MBeanTest - StoreQueueCursor not sharing its audit - have purge use rollback and delegate to both cursors 2018-05-18 11:36:54 +01:00
gtully
8d3674be3d AMQ-6707 - remove duplicated started state flag 2018-05-15 14:55:02 +01:00
gtully
09bf8f89b8 AMQ-6707 - ensure trace logging does not flip cacheEnabled flag outside required sync 2018-05-15 12:00:22 +01:00
gtully
573b366ca0 AMQ-6100 - use setOriginalDestination=false to make this behaviour optional b/c amqp cannot see the original dest property due to immutability of the message properties and folks can depend on the existing original destination behaviour 2018-05-10 10:55:15 +01:00
gtully
c1e7dbd53b AMQ-6707 - fix trace log reporting in error 2018-05-09 12:17:29 +01:00
gtully
ea70e827c0 AMQ-6707 - JDBC XA recovery and completion.
ensure pending transactions are visible for recovery without restart
sync store and cursor size during and after completion
ensure pending messages are not visible to browsers
retain transaction state on jdbc error
a bunch of new tests around xa completion
2018-04-26 14:58:48 +01:00
Christopher L. Shannon (cshannon)
1d2226e6cf Revert "AMQ-6947 - Make sure counters are updated correct on message drop"
This reverts commit 021c82859cf4361eb31b21fdbac17655ae9e368d.
2018-04-18 12:34:18 -04:00
Christopher L. Shannon (cshannon)
7123534e1b Revert "AMQ-6947 - Update Queue metrics on expiration"
This reverts commit 6e468b4540754cad5cd30de373cadc026c998669.
2018-04-18 12:34:07 -04:00
Christopher L. Shannon (cshannon)
6e468b4540 AMQ-6947 - Update Queue metrics on expiration
The updated dropMessage method only decrements the destination metrics
if a message is removed from the pagedInMessages list to prevent
duplicate updates.  There is also a case where we still need to update
metrics if the message never makes it into the pagedInMessages list in
the first place and that is on expiration so this patch fixes that. A
couple existing tests found this issue.
2018-04-18 09:04:11 -04:00
Christopher L. Shannon (cshannon)
021c82859c AMQ-6947 - Make sure counters are updated correct on message drop
Only update metrics counters when message is removed from the
pagedInMessages list which is important to check in case of duplicates
2018-04-17 08:25:08 -04:00
Christopher L. Shannon (cshannon)
65b0f2ad0d AMQ-6940 - Add flag to disable TopicSubscription in flight stats
To save memory usage in some use cases add a new flag to PolicyEntry
called useTopicSubscriptionInflightStats to allow disabling the
inflight stats
2018-03-29 13:25:36 -04:00
Christopher L. Shannon (cshannon)
f69fd6f002 AMQ-6940 - Reduce memory footprint for inflight statistics
For the TopicSubscription case we can reduce the inflight statistics
memory footprint by not storing the entire message reference for in
flight messages and instead just a subset of the information needed.
2018-03-29 09:00:26 -04:00
Christopher L. Shannon (cshannon)
5e2adc0ed7 AMQ-6924 - Fix StoreDurableSubscriberCursor non-persistent message add
StoreDurableSubscriberCursor now properly uses a timeout value when
attempting to add to the temporary store for non-persistent messages to
prevent an indefinite wait on free space
2018-03-09 07:41:09 -05:00