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<>();