Fix apache#299 Use Camel's async processor in platform-http

ppalaga · Oct 29, 2019 · d61ddac · d61ddac
1 parent b5c432c
commit d61ddac
Showing 1 changed file with 8 additions and 3 deletions.
diff --git a/...org/apache/camel/quarkus/component/platform/http/runtime/QuarkusPlatformHttpConsumer.java b/...org/apache/camel/quarkus/component/platform/http/runtime/QuarkusPlatformHttpConsumer.java
@@ -111,13 +111,18 @@ protected void doStart() throws Exception {
 
         newRoute.handler(
             ctx -> {
+                final Exchange exchange = toExchange(ctx);
                 try {
-                    final Exchange e = toExchange(ctx);
-                    getProcessor().process(e);
-                    writeResponse(ctx, e, getEndpoint().getHeaderFilterStrategy());
+                    createUoW(exchange);
+                    getAsyncProcessor().process(
+                        exchange,
+                        doneSync -> writeResponse(ctx, exchange, getEndpoint().getHeaderFilterStrategy())
+                    );
                 } catch (Exception e) {
                     LOG.debugf(e, "Could not handle '%s'", path);
                     ctx.fail(e);
+                } finally {
+                    doneUoW(exchange);
                 }
             }
         );