[camel] branch master updated: [CAMEL-12870]make cxf consumer endpoints suspendable

[ff...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

ffang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/master by this push:
     new e3b9f98  [CAMEL-12870]make cxf consumer endpoints suspendable
e3b9f98 is described below

commit e3b9f98569fcdffecfbda1b37e544bdb57dcc4c2
Author: Freeman Fang <fr...@gmail.com>
AuthorDate: Tue Oct 9 09:04:27 2018 +0800

    [CAMEL-12870]make cxf consumer endpoints suspendable
---
 .../src/main/java/org/apache/camel/component/cxf/CxfConsumer.java      | 3 ++-
 .../main/java/org/apache/camel/component/cxf/jaxrs/CxfRsConsumer.java  | 3 ++-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfConsumer.java b/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfConsumer.java
index be18630..ff6741b 100644
--- a/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfConsumer.java
+++ b/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfConsumer.java
@@ -28,6 +28,7 @@ import org.apache.camel.AsyncCallback;
 import org.apache.camel.ExchangePattern;
 import org.apache.camel.ExchangeTimedOutException;
 import org.apache.camel.Processor;
+import org.apache.camel.Suspendable;
 import org.apache.camel.component.cxf.common.message.CxfConstants;
 import org.apache.camel.component.cxf.interceptors.UnitOfWorkCloserInterceptor;
 import org.apache.camel.component.cxf.util.CxfUtils;
@@ -58,7 +59,7 @@ import org.slf4j.LoggerFactory;
  *
  * @version
  */
-public class CxfConsumer extends DefaultConsumer {
+public class CxfConsumer extends DefaultConsumer implements Suspendable {
     private static final Logger LOG = LoggerFactory.getLogger(CxfConsumer.class);
     private Server server;
     private CxfEndpoint cxfEndpoint;
diff --git a/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/jaxrs/CxfRsConsumer.java b/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/jaxrs/CxfRsConsumer.java
index 4c68e49..a083946 100644
--- a/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/jaxrs/CxfRsConsumer.java
+++ b/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/jaxrs/CxfRsConsumer.java
@@ -17,6 +17,7 @@
 package org.apache.camel.component.cxf.jaxrs;
 
 import org.apache.camel.Processor;
+import org.apache.camel.Suspendable;
 import org.apache.camel.component.cxf.interceptors.UnitOfWorkCloserInterceptor;
 import org.apache.camel.component.cxf.util.CxfUtils;
 import org.apache.camel.impl.DefaultConsumer;
@@ -32,7 +33,7 @@ import org.apache.cxf.transport.MessageObserver;
  * and forward them to Camel route for processing. 
  * It is also responsible for converting and sending back responses to CXF client. 
  */
-public class CxfRsConsumer extends DefaultConsumer {
+public class CxfRsConsumer extends DefaultConsumer implements Suspendable {
     private Server server;
 
     public CxfRsConsumer(CxfRsEndpoint endpoint, Processor processor) {