You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ff...@apache.org on 2021/07/13 17:35:49 UTC
[camel] branch main updated: [CAMEL-16796]camel-cxf - Problem with
inflight message count being -1
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 <fr...@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());
}
}