Commit Graph

814 Commits

Author SHA1 Message Date
giliva 2fe8116819 Avoid overflow errors - see KAFKA-4290
Add test for overflow values

Bind test sockets to free ports

(cherry picked from commit 5b1412ddfd)
2018-07-27 08:39:52 -04:00
gtully cdae25ecfb AMQ-6967 - ensure there are some messages paged in for periodic expiry check if non are in memory
(cherry picked from commit 026c6f4403)
2018-07-27 08:11:34 -04:00
Christopher L. Shannon (cshannon) e3f76e1693 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

(cherry picked from commit b79fcd0a76)
2018-07-27 07:41:22 -04:00
gtully c0a6f47a47 AMQ-7021 - add unsynchronised accessors to destination map for usage with rw lock from abstract region; allow concurrent read of the destination map
(cherry picked from commit 0b76d3a0ea)
2018-07-26 11:31:11 -04:00
Jeff Genender 3397a97213 AMQ-7002 - Change jobid identifier to messageid format 2018-06-27 10:38:30 -06:00
gtully 4cbb913271 AMQ-7002 - ensure uniqueue jobids, fix and test via patch from Jamie goodyear applied with thanks
(cherry picked from commit e0aa091d9e)
2018-06-27 14:17:04 +01:00
Christopher L. Shannon (cshannon) ea1894c7ee [maven-release-plugin] prepare for next development iteration 2018-05-17 13:58:54 -04:00
Christopher L. Shannon (cshannon) 165cba235a [maven-release-plugin] prepare release activemq-5.15.4 2018-05-17 13:57:43 -04:00
Christopher L. Shannon (cshannon) 79fae8c00b Revert "AMQ-6947 - Make sure counters are updated correct on message drop"
This reverts commit 1fe096cb2a.
2018-04-18 12:35:10 -04:00
Christopher L. Shannon (cshannon) 86fbf957e9 Revert "AMQ-6947 - Update Queue metrics on expiration"
This reverts commit bca0af4133.
2018-04-18 12:35:01 -04:00
Christopher L. Shannon (cshannon) bca0af4133 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.

(cherry picked from commit 6e468b4540)
2018-04-18 09:06:31 -04:00
Christopher L. Shannon (cshannon) 1fe096cb2a 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

(cherry picked from commit 021c82859c)
2018-04-17 08:25:56 -04:00
Christopher L. Shannon (cshannon) a0a240372f AMQ-6940 - fix compilation attempt 2 2018-03-30 06:31:04 -04:00
Christopher L. Shannon (cshannon) 9346fb3638 AMQ-6940 - Fix compilation 2018-03-30 06:29:25 -04:00
Christopher L. Shannon (cshannon) 21a594c8e8 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

(cherry picked from commit 65b0f2ad0d)
2018-03-29 13:26:13 -04:00
Christopher L. Shannon (cshannon) cae382063e 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.

(cherry picked from commit f69fd6f002)
2018-03-29 09:02:20 -04:00
Christopher L. Shannon (cshannon) 2ca46c561b 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

(cherry picked from commit 5e2adc0ed7)
2018-03-09 07:41:38 -05:00
Christopher L. Shannon (cshannon) bb2db5741b [maven-release-plugin] prepare for next development iteration 2018-01-29 08:46:14 -05:00
Christopher L. Shannon (cshannon) bd4285d3aa [maven-release-plugin] prepare release activemq-5.15.3 2018-01-29 08:42:12 -05:00
Christopher L. Shannon (cshannon) 164312f888 NO-JIRA: Add missing license headers
(cherry picked from commit e5de25f4fc)
2018-01-29 08:12:16 -05:00
Łukasz Dywicki 3e9ee71062 AMQ-6861 Allow customisation of network bridge creation logic. 2017-12-20 22:17:17 -05:00
gtully 0464d53233 [AMQ-6847] limit the retry loop to one iteration overa all pending messages such that new additions are not replayed to avoid duplicates
(cherry picked from commit 03b19b9da4)
2017-12-19 07:18:12 -05:00
gtully eb9e50f3c9 [AMQ-6847] pause dispatch for message move to avoid redelivery with pending ack/remove/audit rollback
(cherry picked from commit 2ea5d1420b)
2017-12-19 07:18:01 -05:00
Christopher L. Shannon (cshannon) 94aea677ac AMQ-6875 - Use the correct destination for Virtual destination consumers
when using Virtual Topics

(cherry picked from commit 56baba96c6)
2017-12-14 16:02:06 -05:00
Christopher L. Shannon (cshannon) 1cfc9ff9a6 (AMQ-6858) - add extra precautionary check for demand subs
also remove test that intermittently fails with timing issues

(cherry picked from commit 08aa5118ff)
2017-11-16 07:50:53 -05:00
Christopher L. Shannon (cshannon) 247243c9c1 AMQ-6858 - handle resync of network proxy durables after restart
We need to properly handle the re-addition of network proxy durables
after the brokers are restarted so removal is done properly

(cherry picked from commit 6013441a9a)
2017-11-16 07:50:40 -05:00
Christopher L. Shannon (cshannon) 39d6321a4a AMQ-6858 - Allow configuration of the client Id token in network bridge
The client id token that is used to separate parts of a generated local
client id in a network bridge should be configurable so bridge names and
broker names can contain underscores if desired

(cherry picked from commit 3ca439cada)
2017-11-16 07:50:31 -05:00
Christopher L. Shannon 97fe20a572 AMQ-6858 - reworking durable subscription propagation fix
Significantly reworking previous fix so that the client id is properly
changed when tracking network proxy subscriptions. This makes it so
removal is done properly

(cherry picked from commit 41211c78d1)
2017-11-16 07:50:19 -05:00
Christopher L. Shannon (cshannon) d5a987b6a5 AMQ-6858 - Fix several durable subscription bridge propagation issues
Durable network proxy subs will now be properly created across multiple
bridges when 3 or more brokers are used.  Demand will be properly synced
and removed.

(cherry picked from commit 96ce14b278)
2017-11-16 07:50:12 -05:00
Christopher L. Shannon (cshannon) c4d460bf60 [maven-release-plugin] prepare for next development iteration 2017-10-17 10:16:08 -04:00
Christopher L. Shannon (cshannon) 9e595d8674 [maven-release-plugin] prepare release activemq-5.15.2 2017-10-17 10:09:04 -04:00
Christopher L. Shannon (cshannon) a218119e6b [maven-release-plugin] prepare for next development iteration 2017-09-28 10:45:21 -04:00
Christopher L. Shannon (cshannon) d17a8740fc [maven-release-plugin] prepare release activemq-5.15.1 2017-09-28 10:28:20 -04:00
Christopher L. Shannon (cshannon) 1d0121ccd4 Revert "[maven-release-plugin] prepare release activemq-5.15.1"
This reverts commit 756b858fa4.
2017-09-28 10:05:01 -04:00
Christopher L. Shannon (cshannon) 756b858fa4 [maven-release-plugin] prepare release activemq-5.15.1 2017-09-28 09:59:18 -04:00
Christopher L. Shannon (cshannon) 76474fbc67 Revert "[maven-release-plugin] prepare release activemq-5.15.1"
This reverts commit 37227fbf8b.
2017-09-27 08:54:44 -04:00
Christopher L. Shannon (cshannon) ade1a87e09 Revert "[maven-release-plugin] prepare for next development iteration"
This reverts commit e2eabeb1c2.
2017-09-27 08:54:36 -04:00
gtully 26788f5fd7 [AMQ-6824] - fix up prefetchExtension growth on transaction completion and delivered ack and tie in boolean usePrefetchExtension
(cherry picked from commit 41a100766c)
2017-09-26 14:34:47 -04:00
Christopher L. Shannon (cshannon) e2eabeb1c2 [maven-release-plugin] prepare for next development iteration 2017-09-25 09:23:32 -04:00
Christopher L. Shannon (cshannon) 37227fbf8b [maven-release-plugin] prepare release activemq-5.15.1 2017-09-25 09:17:38 -04:00
Erik Wramner e1699d58c8 AMQ-6808 preserve destination for browsed scheduled messages
(cherry picked from commit c691124d32)
2017-09-15 09:03:58 -04:00
Dejan Bosanac 9387451412 https://issues.apache.org/jira/browse/AMQ-6799 - stop the jmx server connector properly
(cherry picked from commit 5e656d394c)
2017-09-07 12:14:45 -04:00
Dejan Bosanac ccf8dbe28b https://issues.apache.org/jira/browse/AMQ-6799 - IOExceptionHandler during the startup
(cherry picked from commit c7291f1ecf)
2017-09-07 12:14:35 -04:00
gtully 0924f983f8 [AMQ-6792] fire the failover exception handler before stop to ensure blocked write does not block stop request
(cherry picked from commit 63f0b7e20d)
2017-09-07 12:14:23 -04:00
Christian Schneider d5dfadd8d0 [AMQ-6788] Explain how to fix the problem in the exception
(cherry picked from commit 8646bb1010)
2017-09-07 12:13:55 -04:00
gtully 3b6ba778bd [AMQ-6643] refine fix to allow wildcard subs to non wildcard subscription queues, enable simple wildcard sub to drain all subscription queues
(cherry picked from commit a67c75a9e1)
2017-09-07 12:13:40 -04:00
gtully 035baf1722 [AMQ-6787] release securty context on failure to addConnection subsequent to auth, resolve leak. fix and test
(cherry picked from commit a15626193c)
2017-09-07 12:13:29 -04:00
gtully 1bba73dcb6 [AMQ-6778] fix and test - no longer gate firing advisory on broker start flag b/c consumers may be present once transport connectors have started
(cherry picked from commit ddfa96028c)
2017-09-07 12:10:55 -04:00
gtully 7ab743a053 [AMQ-6764] add logging of exit of jmx ops such that overlaps and delays are visible in the audit. fix and test
(cherry picked from commit d7f70837b7)
2017-09-07 12:09:56 -04:00
Christopher L. Shannon (cshannon) eca72dc81a AMQ-6798 - Clean up store usage object on Queue stop
When queues are stopped the StoreUsage object needs to be stopped so it
will be removed from the parent StoreUsage.  This allows the object to
be garbage collected and prevents a memory leak.

(cherry picked from commit 35bd3ad938)
2017-08-24 09:25:13 -04:00