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


The following commit(s) were added to refs/heads/master by this push:
     new c892e86  CAMEL-14354: Optimize core and fixed test
c892e86 is described below

commit c892e864196a4c15db816daa0cbbf1c8496b0cfe
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Sat Jan 18 20:15:48 2020 +0100

    CAMEL-14354: Optimize core and fixed test
---
 .../metrics/MicroProfileMetricsExchangeRecorderTest.java       | 10 ----------
 .../org/apache/camel/component/undertow/ExchangeHeaders.java   |  1 +
 core/camel-api/src/main/java/org/apache/camel/Exchange.java    |  1 +
 .../camel/management/ManagedDefaultReactiveExecutorTest.java   |  2 +-
 4 files changed, 3 insertions(+), 11 deletions(-)

diff --git 
a/components/camel-microprofile-metrics/src/test/java/org/apache/camel/component/microprofile/metrics/MicroProfileMetricsExchangeRecorderTest.java
 
b/components/camel-microprofile-metrics/src/test/java/org/apache/camel/component/microprofile/metrics/MicroProfileMetricsExchangeRecorderTest.java
index 20220b5..dd82b5c 100644
--- 
a/components/camel-microprofile-metrics/src/test/java/org/apache/camel/component/microprofile/metrics/MicroProfileMetricsExchangeRecorderTest.java
+++ 
b/components/camel-microprofile-metrics/src/test/java/org/apache/camel/component/microprofile/metrics/MicroProfileMetricsExchangeRecorderTest.java
@@ -80,16 +80,6 @@ public class MicroProfileMetricsExchangeRecorderTest extends 
MicroProfileMetrics
     }
 
     @Test
-    public void testMetricsRecorderExternalRedeliveries() {
-        Exchange exchange = ExchangeBuilder.anExchange(context)
-            .withProperty(Exchange.EXTERNAL_REDELIVERED, true)
-            .build();
-        recorder.recordExchangeComplete(exchange);
-        Counter externalRedeliveries = getCounter(CAMEL_METRIC_PREFIX + 
EXCHANGES_EXTERNAL_REDELIVERIES_METRIC_NAME, TAGS);
-        assertEquals(1, externalRedeliveries.getCount());
-    }
-
-    @Test
     public void testMetricsRecorderFailuresHandled() {
         Exchange exchange = ExchangeBuilder.anExchange(context)
             .withProperty(Exchange.FAILURE_HANDLED, true)
diff --git 
a/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/ExchangeHeaders.java
 
b/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/ExchangeHeaders.java
index 08d7bbe..ad3d373 100644
--- 
a/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/ExchangeHeaders.java
+++ 
b/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/ExchangeHeaders.java
@@ -64,6 +64,7 @@ public final class ExchangeHeaders {
     public static final HttpString EXCEPTION_HANDLED = new 
HttpString("CamelExceptionHandled");
     public static final HttpString EVALUATE_EXPRESSION_RESULT = new 
HttpString("CamelEvaluateExpressionResult");
     public static final HttpString ERRORHANDLER_HANDLED = new 
HttpString("CamelErrorHandlerHandled");
+    @Deprecated
     public static final HttpString EXTERNAL_REDELIVERED = new 
HttpString("CamelExternalRedelivered");
 
     public static final HttpString FAILURE_HANDLED = new 
HttpString("CamelFailureHandled");
diff --git a/core/camel-api/src/main/java/org/apache/camel/Exchange.java 
b/core/camel-api/src/main/java/org/apache/camel/Exchange.java
index 49ab34e..161932f 100644
--- a/core/camel-api/src/main/java/org/apache/camel/Exchange.java
+++ b/core/camel-api/src/main/java/org/apache/camel/Exchange.java
@@ -119,6 +119,7 @@ public interface Exchange {
     String EVALUATE_EXPRESSION_RESULT    = "CamelEvaluateExpressionResult";
     String ERRORHANDLER_CIRCUIT_DETECTED = "CamelFErrorHandlerCircuitDetected";
     String ERRORHANDLER_HANDLED          = "CamelErrorHandlerHandled";
+    @Deprecated
     String EXTERNAL_REDELIVERED          = "CamelExternalRedelivered";
 
     String FAILURE_HANDLED      = "CamelFailureHandled";
diff --git 
a/core/camel-management/src/test/java/org/apache/camel/management/ManagedDefaultReactiveExecutorTest.java
 
b/core/camel-management/src/test/java/org/apache/camel/management/ManagedDefaultReactiveExecutorTest.java
index a6cb317..a9eb455 100644
--- 
a/core/camel-management/src/test/java/org/apache/camel/management/ManagedDefaultReactiveExecutorTest.java
+++ 
b/core/camel-management/src/test/java/org/apache/camel/management/ManagedDefaultReactiveExecutorTest.java
@@ -56,7 +56,7 @@ public class ManagedDefaultReactiveExecutorTest extends 
ManagementTestSupport {
                             assertEquals(1, running.intValue());
 
                             // should be 0 pending
-                            Long pending = (Long) mbeanServer.getAttribute(on, 
"PendingTasks");
+                            Integer pending = (Integer) 
mbeanServer.getAttribute(on, "PendingTasks");
                             assertEquals(0, pending.intValue());
                         }
                     })

Reply via email to