You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2021/04/05 16:47:12 UTC
[camel] 04/05: camel-core - Fixed
java.util.ConcurrentModificationException when using extended endpoint
utilization statistics.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit c8dd38846531b5df0be262a6f7b890934670ecab
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Mon Apr 5 17:37:18 2021 +0200
camel-core - Fixed java.util.ConcurrentModificationException when using extended endpoint utilization statistics.
---
.../main/java/org/apache/camel/spi/EndpointUtilizationStatistics.java | 2 +-
.../src/main/java/org/apache/camel/processor/WireTapProcessor.java | 1 -
.../org/apache/camel/support/DefaultEndpointUtilizationStatistics.java | 3 ++-
3 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/core/camel-api/src/main/java/org/apache/camel/spi/EndpointUtilizationStatistics.java b/core/camel-api/src/main/java/org/apache/camel/spi/EndpointUtilizationStatistics.java
index 990389e..17060fa 100644
--- a/core/camel-api/src/main/java/org/apache/camel/spi/EndpointUtilizationStatistics.java
+++ b/core/camel-api/src/main/java/org/apache/camel/spi/EndpointUtilizationStatistics.java
@@ -34,7 +34,7 @@ public interface EndpointUtilizationStatistics {
int size();
/**
- * Callback when an endpoint is being utilizated by an {@link org.apache.camel.Processor} EIP such as sending a
+ * Callback when an endpoint is being utilized by an {@link org.apache.camel.Processor} EIP such as sending a
* message to a dynamic endpoint.
*
* @param uri the endpoint uri
diff --git a/core/camel-core-processor/src/main/java/org/apache/camel/processor/WireTapProcessor.java b/core/camel-core-processor/src/main/java/org/apache/camel/processor/WireTapProcessor.java
index f3b90d4..f90f7f2 100644
--- a/core/camel-core-processor/src/main/java/org/apache/camel/processor/WireTapProcessor.java
+++ b/core/camel-core-processor/src/main/java/org/apache/camel/processor/WireTapProcessor.java
@@ -44,7 +44,6 @@ import org.apache.camel.spi.RouteIdAware;
import org.apache.camel.spi.ShutdownAware;
import org.apache.camel.support.AsyncProcessorConverterHelper;
import org.apache.camel.support.AsyncProcessorSupport;
-import org.apache.camel.support.DefaultExchange;
import org.apache.camel.support.service.ServiceHelper;
import org.apache.camel.util.ObjectHelper;
import org.slf4j.Logger;
diff --git a/core/camel-support/src/main/java/org/apache/camel/support/DefaultEndpointUtilizationStatistics.java b/core/camel-support/src/main/java/org/apache/camel/support/DefaultEndpointUtilizationStatistics.java
index abea2e1..ae024ec 100644
--- a/core/camel-support/src/main/java/org/apache/camel/support/DefaultEndpointUtilizationStatistics.java
+++ b/core/camel-support/src/main/java/org/apache/camel/support/DefaultEndpointUtilizationStatistics.java
@@ -18,6 +18,7 @@ package org.apache.camel.support;
import java.util.Collections;
import java.util.Map;
+import java.util.concurrent.ConcurrentMap;
import org.apache.camel.spi.EndpointUtilizationStatistics;
@@ -43,7 +44,7 @@ public class DefaultEndpointUtilizationStatistics implements EndpointUtilization
}
@Override
- public void onHit(String uri) {
+ public synchronized void onHit(String uri) {
map.compute(uri, (key, current) -> {
if (current == null) {
return 1L;