You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cs...@apache.org on 2019/07/31 18:09:52 UTC
[activemq] 04/04: AMQ-7102 - Improve ManagedRegionBroker
performance by replacing registeredMBeans CopyOnWriteSet with a Concurrent
hashmap backed set
This is an automated email from the ASF dual-hosted git repository.
cshannon pushed a commit to branch activemq-5.15.x
in repository https://gitbox.apache.org/repos/asf/activemq.git
commit e652e18b5de54ecb4686b2a69e0e43067954a0f2
Author: Christopher L. Shannon (cshannon) <ch...@gmail.com>
AuthorDate: Wed Jul 31 12:55:24 2019 -0400
AMQ-7102 - Improve ManagedRegionBroker performance by replacing
registeredMBeans CopyOnWriteSet with a Concurrent hashmap backed set
(cherry picked from commit 09003e8fef27f51b83a5ee4242709c2b20821a83)
---
.../main/java/org/apache/activemq/broker/jmx/ManagedRegionBroker.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ManagedRegionBroker.java b/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ManagedRegionBroker.java
index 3eaf28b..e856c5d 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ManagedRegionBroker.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ManagedRegionBroker.java
@@ -96,7 +96,7 @@ public class ManagedRegionBroker extends RegionBroker {
private final Map<ObjectName, ProducerView> dynamicDestinationProducers = new ConcurrentHashMap<ObjectName, ProducerView>();
private final Map<SubscriptionKey, ObjectName> subscriptionKeys = new ConcurrentHashMap<SubscriptionKey, ObjectName>();
private final Map<Subscription, ObjectName> subscriptionMap = new ConcurrentHashMap<Subscription, ObjectName>();
- private final Set<ObjectName> registeredMBeans = new CopyOnWriteArraySet<ObjectName>();
+ private final Set<ObjectName> registeredMBeans = new ConcurrentHashMap<>().newKeySet();
/* This is the first broker in the broker interceptor chain. */
private Broker contextBroker;