[camel] branch main updated: [CAMEL-16796]camel-cxf - Problem with inflight message count being -1

[ffang]

This is an automated email from the ASF dual-hosted git repository.

ffang pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/main by this push:
     new 45e64cc  [CAMEL-16796]camel-cxf - Problem with inflight message count 
being -1
45e64cc is described below

commit 45e64cce8ad2e1d22a5f55be13a6dfcaa504f58f
Author: Freeman Fang <freeman.f...@gmail.com>
AuthorDate: Tue Jul 13 13:35:19 2021 -0400

    [CAMEL-16796]camel-cxf - Problem with inflight message count being -1
---
 .../src/main/java/org/apache/camel/component/cxf/CxfConsumer.java       | 2 --
 .../org/apache/camel/component/cxf/CxfConsumerPayloadFaultTest.java     | 1 +
 2 files changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfConsumer.java
 
b/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfConsumer.java
index 193e9d6..45cedf6 100644
--- 
a/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfConsumer.java
+++ 
b/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfConsumer.java
@@ -31,7 +31,6 @@ import org.apache.camel.Processor;
 import org.apache.camel.Suspendable;
 import org.apache.camel.component.cxf.common.message.CxfConstants;
 import org.apache.camel.component.cxf.interceptors.UnitOfWorkCloserInterceptor;
-import org.apache.camel.component.cxf.util.CxfUtils;
 import org.apache.camel.support.DefaultConsumer;
 import org.apache.camel.util.ObjectHelper;
 import org.apache.cxf.continuations.Continuation;
@@ -84,7 +83,6 @@ public class CxfConsumer extends DefaultConsumer implements 
Suspendable {
         final MessageObserver originalOutFaultObserver = 
server.getEndpoint().getOutFaultObserver();
         server.getEndpoint().setOutFaultObserver(message -> {
             originalOutFaultObserver.onMessage(message);
-            CxfUtils.closeCamelUnitOfWork(message);
         });
 
         // setup the UnitOfWorkCloserInterceptor for OneWayMessageProcessor
diff --git 
a/components/camel-cxf/src/test/java/org/apache/camel/component/cxf/CxfConsumerPayloadFaultTest.java
 
b/components/camel-cxf/src/test/java/org/apache/camel/component/cxf/CxfConsumerPayloadFaultTest.java
index 096c369..5641509 100644
--- 
a/components/camel-cxf/src/test/java/org/apache/camel/component/cxf/CxfConsumerPayloadFaultTest.java
+++ 
b/components/camel-cxf/src/test/java/org/apache/camel/component/cxf/CxfConsumerPayloadFaultTest.java
@@ -110,6 +110,7 @@ public class CxfConsumerPayloadFaultTest extends 
CamelTestSupport {
 
         assertNotNull(t);
         assertTrue(t instanceof UnknownPersonFault);
+        assertEquals(0, context.getInflightRepository().size());
 
     }
 }