This is an automated email from the ASF dual-hosted git repository. ffang pushed a commit to branch camel-2.x in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-2.x by this push: new b7e4ba4 [CAMEL-14368]can't gracefully shutdown a camel-undertow consumer endpoint b7e4ba4 is described below commit b7e4ba4c22f147c0de1fa0ec4fbb1397fd41d542 Author: Freeman Fang <freeman.f...@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) --- .../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 148c2b9..7dc8fc7 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 @@ -40,6 +40,7 @@ import org.apache.camel.Exchange; import org.apache.camel.Message; import org.apache.camel.NoTypeConversionAvailableException; 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; @@ -53,7 +54,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;