This is an automated email from the ASF dual-hosted git repository.
tandraschko pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/deltaspike.git
The following commit(s) were added to refs/heads/master by this push:
new 8ed131e DELTASPIKE-1375
8ed131e is described below
commit 8ed131eac40d598ba630ec9aba77569551a2db5c
Author: Thomas Andraschko <tandrasc...@apache.org>
AuthorDate: Mon Mar 25 11:21:39 2019 +0100
DELTASPIKE-1375
---
.../core/impl/future/ThreadPoolManager.java | 2 +-
.../test/core/impl/future/ThreadPoolManagerTest.java | 2 +-
documentation/src/main/asciidoc/core.adoc | 20 ++++++++++----------
3 files changed, 12 insertions(+), 12 deletions(-)
diff --git
a/deltaspike/core/impl/src/main/java/org/apache/deltaspike/core/impl/future/ThreadPoolManager.java
b/deltaspike/core/impl/src/main/java/org/apache/deltaspike/core/impl/future/ThreadPoolManager.java
index e85f847..1041331 100644
---
a/deltaspike/core/impl/src/main/java/org/apache/deltaspike/core/impl/future/ThreadPoolManager.java
+++
b/deltaspike/core/impl/src/main/java/org/apache/deltaspike/core/impl/future/ThreadPoolManager.java
@@ -147,7 +147,7 @@ public class ThreadPoolManager
if (pool == null) // 3.
{
- final String configPrefix = "futurable.pool." + name +
".";
+ final String configPrefix = "futureable.pool." + name
+ ".";
final int coreSize =
ConfigResolver.resolve(configPrefix + "coreSize")
.as(Integer.class)
.withDefault(Math.max(2,
Runtime.getRuntime().availableProcessors()))
diff --git
a/deltaspike/core/impl/src/test/java/org/apache/deltaspike/test/core/impl/future/ThreadPoolManagerTest.java
b/deltaspike/core/impl/src/test/java/org/apache/deltaspike/test/core/impl/future/ThreadPoolManagerTest.java
index f1c4ec0..25093cc 100644
---
a/deltaspike/core/impl/src/test/java/org/apache/deltaspike/test/core/impl/future/ThreadPoolManagerTest.java
+++
b/deltaspike/core/impl/src/test/java/org/apache/deltaspike/test/core/impl/future/ThreadPoolManagerTest.java
@@ -83,7 +83,7 @@ public class ThreadPoolManagerTest
{
ConfigResolver.addConfigSources(Collections.<ConfigSource>singletonList(new
PropertiesConfigSource(new Properties()
{{
- setProperty("futurable.pool.custom.coreSize", "5");
+ setProperty("futureable.pool.custom.coreSize", "5");
}})
{
@Override
diff --git a/documentation/src/main/asciidoc/core.adoc
b/documentation/src/main/asciidoc/core.adoc
index 94fc16d..0c39cb9 100644
--- a/documentation/src/main/asciidoc/core.adoc
+++ b/documentation/src/main/asciidoc/core.adoc
@@ -1196,16 +1196,16 @@ If you rely on the last option (configured executor)
here are the keys you can s
|===
| Key | Description | Default
-| futurable.pool.<pool name>.coreSize | The core size of the pool. | Number of
available processors
-| futurable.pool.<pool name>.maxSize | The max size of the pool. | coreSize
value
-| futurable.pool.<pool name>.keepAlive.value | Pool keep alive (when a thread
is released). | 0
-| futurable.pool.<pool name>.keepAlive.unit | Unit of keepAlive.value. It must
match a `TIMEUNIT` name. | MILLISECONDS
-| futurable.pool.<pool name>.queue.type | The task queue type of the executor.
Can be `ARRAY` to use an `ArrayBlockingQueue`, `LINKED` for a
`LinkedBlockingQueue` or `SYNCHRONOUS` for a `SynchronousQueue`. | LINKED
-| futurable.pool.<pool name>.queue.fair | For synchronous and array queue
types, if the queue is fair. | false
-| futurable.pool.<pool name>.queue.size | For array queue type, the size of
the queue. | 1024
-| futurable.pool.<pool name>.queue.capacity | For linked queue type, the
capacity of the queue. | `Integer.MAX_VALUE`
-| futurable.pool.<pool name>.threadFactory.name | If set a CDI bean matching
the value will be looked up and used as `ThreadFactory`. | none,
`Executors.defaultThreadFactory()` is used
-| futurable.pool.<pool name>.rejectedExecutionHandler.name | If set a CDI bean
matching the value will be looked up and used as `RejectedExecutionHandler`. |
none, `ThreadPoolExecutor.AbortPolicy` is used
+| futureable.pool.<pool name>.coreSize | The core size of the pool. | Number
of available processors
+| futureable.pool.<pool name>.maxSize | The max size of the pool. | coreSize
value
+| futureable.pool.<pool name>.keepAlive.value | Pool keep alive (when a thread
is released). | 0
+| futureable.pool.<pool name>.keepAlive.unit | Unit of keepAlive.value. It
must match a `TIMEUNIT` name. | MILLISECONDS
+| futureable.pool.<pool name>.queue.type | The task queue type of the
executor. Can be `ARRAY` to use an `ArrayBlockingQueue`, `LINKED` for a
`LinkedBlockingQueue` or `SYNCHRONOUS` for a `SynchronousQueue`. | LINKED
+| futureable.pool.<pool name>.queue.fair | For synchronous and array queue
types, if the queue is fair. | false
+| futureable.pool.<pool name>.queue.size | For array queue type, the size of
the queue. | 1024
+| futureable.pool.<pool name>.queue.capacity | For linked queue type, the
capacity of the queue. | `Integer.MAX_VALUE`
+| futureable.pool.<pool name>.threadFactory.name | If set a CDI bean matching
the value will be looked up and used as `ThreadFactory`. | none,
`Executors.defaultThreadFactory()` is used
+| futureable.pool.<pool name>.rejectedExecutionHandler.name | If set a CDI
bean matching the value will be looked up and used as
`RejectedExecutionHandler`. | none, `ThreadPoolExecutor.AbortPolicy` is used
|===
== Utilities
