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;

Reply via email to