This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch camel-13636 in repository https://gitbox.apache.org/repos/asf/camel.git
commit 2d5982ed4e85cb243b29e2a6a835b1b459ebfaa6 Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Wed Jun 12 14:35:58 2019 +0200 BaseExecutorServiceManager should be abstract --- .../org/apache/camel/impl/engine/BaseExecutorServiceManager.java | 5 ++--- .../java/org/apache/camel/impl/DefaultExecutorServiceManager.java | 3 +++ .../org/apache/camel/impl/engine/CustomThreadPoolFactoryTest.java | 3 ++- 3 files changed, 7 insertions(+), 4 deletions(-) diff --git a/core/camel-base/src/main/java/org/apache/camel/impl/engine/BaseExecutorServiceManager.java b/core/camel-base/src/main/java/org/apache/camel/impl/engine/BaseExecutorServiceManager.java index 67c4e56..5dfd1e5 100644 --- a/core/camel-base/src/main/java/org/apache/camel/impl/engine/BaseExecutorServiceManager.java +++ b/core/camel-base/src/main/java/org/apache/camel/impl/engine/BaseExecutorServiceManager.java @@ -52,10 +52,9 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** - * Default {@link org.apache.camel.spi.ExecutorServiceManager}. - * + * Base {@link org.apache.camel.spi.ExecutorServiceManager} which can be used for implementations */ -public class BaseExecutorServiceManager extends ServiceSupport implements ExecutorServiceManager { +public abstract class BaseExecutorServiceManager extends ServiceSupport implements ExecutorServiceManager { private static final Logger LOG = LoggerFactory.getLogger(BaseExecutorServiceManager.class); private final CamelContext camelContext; diff --git a/core/camel-core/src/main/java/org/apache/camel/impl/DefaultExecutorServiceManager.java b/core/camel-core/src/main/java/org/apache/camel/impl/DefaultExecutorServiceManager.java index b9eb1a1..a75bcbc 100644 --- a/core/camel-core/src/main/java/org/apache/camel/impl/DefaultExecutorServiceManager.java +++ b/core/camel-core/src/main/java/org/apache/camel/impl/DefaultExecutorServiceManager.java @@ -26,6 +26,9 @@ import org.apache.camel.model.OptionalIdentifiedDefinition; import org.apache.camel.spi.NodeIdFactory; import org.apache.camel.spi.ThreadPoolProfile; +/** + * Default {@link org.apache.camel.spi.ExecutorServiceManager}. + */ public class DefaultExecutorServiceManager extends BaseExecutorServiceManager { public DefaultExecutorServiceManager(CamelContext camelContext) { diff --git a/core/camel-core/src/test/java/org/apache/camel/impl/engine/CustomThreadPoolFactoryTest.java b/core/camel-core/src/test/java/org/apache/camel/impl/engine/CustomThreadPoolFactoryTest.java index f9995a0..59de11f 100644 --- a/core/camel-core/src/test/java/org/apache/camel/impl/engine/CustomThreadPoolFactoryTest.java +++ b/core/camel-core/src/test/java/org/apache/camel/impl/engine/CustomThreadPoolFactoryTest.java @@ -23,6 +23,7 @@ import java.util.concurrent.TimeUnit; import org.apache.camel.CamelContext; import org.apache.camel.ContextTestSupport; +import org.apache.camel.impl.DefaultExecutorServiceManager; import org.apache.camel.support.DefaultThreadPoolFactory; import org.junit.Test; @@ -36,7 +37,7 @@ public class CustomThreadPoolFactoryTest extends ContextTestSupport { @Override protected CamelContext createCamelContext() throws Exception { CamelContext context = super.createCamelContext(); - BaseExecutorServiceManager executorServiceManager = new BaseExecutorServiceManager(context); + DefaultExecutorServiceManager executorServiceManager = new DefaultExecutorServiceManager(context); executorServiceManager.setThreadPoolFactory(factory); context.setExecutorServiceManager(executorServiceManager); return context;