fix apache/camel-k#1119: removing unneeded wrapper for reply processor

apache · Dec 13, 2019 · 5fd7e2f · 5fd7e2f
1 parent e88731e
commit 5fd7e2f
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 54 deletions.
diff --git a/...ative/camel-knative/src/main/java/org/apache/camel/component/knative/KnativeEndpoint.java b/...ative/camel-knative/src/main/java/org/apache/camel/component/knative/KnativeEndpoint.java
@@ -92,7 +92,10 @@ public Producer createProducer() throws Exception {
     public Consumer createConsumer(Processor processor) throws Exception {
         final KnativeEnvironment.KnativeServiceDefinition service = lookupServiceDefinition(Knative.EndpointKind.source);
         final Processor ceProcessor = cloudEvent.consumer(this, service);
-        final Processor replyProcessor = new KnativeReplyProcessor(this, service, cloudEvent, configuration.isReplyWithCloudEvent());
+        Processor replyProcessor = null;
+        if (configuration.isReplyWithCloudEvent()) {
+            replyProcessor = cloudEvent.producer(this, service);
+        }
         final Processor pipeline = Pipeline.newInstance(getCamelContext(), ceProcessor, processor, replyProcessor);
         final Consumer consumer = getComponent().getTransport().createConsumer(this, createTransportConfiguration(), service, pipeline);
 

diff --git a/...camel-knative/src/main/java/org/apache/camel/component/knative/KnativeReplyProcessor.java b/...camel-knative/src/main/java/org/apache/camel/component/knative/KnativeReplyProcessor.java