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 2020/01/08 15:17:02 UTC
[camel] branch camel-2.24.x updated: [CAMEL-14368]can't gracefully
shutdown a camel-undertow consumer endpoint
This is an automated email from the ASF dual-hosted git repository.
ffang pushed a commit to branch camel-2.24.x
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-2.24.x by this push:
new ba7a1bb [CAMEL-14368]can't gracefully shutdown a camel-undertow consumer endpoint
ba7a1bb is described below
commit ba7a1bb05eb118aa325c4723b168e83340dce985
Author: Freeman Fang <fr...@gmail.com>
AuthorDate: Wed Jan 8 10:01:19 2020 -0500
[CAMEL-14368]can't gracefully shutdown a camel-undertow consumer endpoint
(cherry picked from commit d0f05945a74caff34353b8474c9915b7cb8d298d)
(cherry picked from commit b7e4ba4c22f147c0de1fa0ec4fbb1397fd41d542)
---
.../java/org/apache/camel/component/undertow/UndertowConsumer.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/UndertowConsumer.java b/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/UndertowConsumer.java
index e15e3a9..3080178 100644
--- a/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/UndertowConsumer.java
+++ b/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/UndertowConsumer.java
@@ -35,6 +35,7 @@ import org.apache.camel.AsyncCallback;
import org.apache.camel.Exchange;
import org.apache.camel.Message;
import org.apache.camel.Processor;
+import org.apache.camel.Suspendable;
import org.apache.camel.TypeConverter;
import org.apache.camel.component.undertow.UndertowConstants.EventType;
import org.apache.camel.component.undertow.handlers.CamelWebSocketHandler;
@@ -47,7 +48,7 @@ import org.slf4j.LoggerFactory;
/**
* The Undertow consumer which is also an Undertow HttpHandler implementation to handle incoming request.
*/
-public class UndertowConsumer extends DefaultConsumer implements HttpHandler {
+public class UndertowConsumer extends DefaultConsumer implements HttpHandler, Suspendable {
private static final Logger LOG = LoggerFactory.getLogger(UndertowConsumer.class);
private CamelWebSocketHandler webSocketHandler;