You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2019/09/02 14:28:44 UTC

[camel] 09/11: CAMEL-13929: camel3 - ApiEndpoint should extend ScheduledPollEndpoint

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

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

commit 8fb880df9bb2535913d09f791789b639adc958ce
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Mon Sep 2 15:36:38 2019 +0200

    CAMEL-13929: camel3 - ApiEndpoint should extend ScheduledPollEndpoint
---
 .../java/org/apache/camel/support/component/AbstractApiEndpoint.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/core/camel-support/src/main/java/org/apache/camel/support/component/AbstractApiEndpoint.java b/core/camel-support/src/main/java/org/apache/camel/support/component/AbstractApiEndpoint.java
index da4b2c9..46d4bec 100644
--- a/core/camel-support/src/main/java/org/apache/camel/support/component/AbstractApiEndpoint.java
+++ b/core/camel-support/src/main/java/org/apache/camel/support/component/AbstractApiEndpoint.java
@@ -31,7 +31,7 @@ import org.apache.camel.Component;
 import org.apache.camel.spi.ExecutorServiceManager;
 import org.apache.camel.spi.ThreadPoolProfile;
 import org.apache.camel.spi.UriParam;
-import org.apache.camel.support.DefaultEndpoint;
+import org.apache.camel.support.ScheduledPollEndpoint;
 import org.apache.camel.util.ObjectHelper;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -40,7 +40,7 @@ import org.slf4j.LoggerFactory;
  * Abstract base class for API Component Endpoints.
  */
 public abstract class AbstractApiEndpoint<E extends ApiName, T>
-    extends DefaultEndpoint implements PropertyNamesInterceptor, PropertiesInterceptor {
+    extends ScheduledPollEndpoint implements PropertyNamesInterceptor, PropertiesInterceptor {
 
     // thread pool executor with Endpoint Class name as keys
     private static Map<String, ExecutorService> executorServiceMap = new ConcurrentHashMap<>();