You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@karaf.apache.org by jb...@apache.org on 2019/10/27 20:17:17 UTC
[karaf-decanter] branch master updated: [KARAF-6475] Fix parse integer property
This is an automated email from the ASF dual-hosted git repository.
jbonofre pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/karaf-decanter.git
The following commit(s) were added to refs/heads/master by this push:
new 698e766 [KARAF-6475] Fix parse integer property
new 02dda09 Merge pull request #103 from fpapon/KARAF-6475
698e766 is described below
commit 698e766d481e65d4fd12d164c624acc8adf313d0
Author: Francois Papon <fr...@openobject.fr>
AuthorDate: Sun Oct 27 10:05:59 2019 +0100
[KARAF-6475] Fix parse integer property
---
.../org/apache/karaf/decanter/collector/system/SystemCollector.java | 2 +-
.../apache/karaf/decanter/collector/system/SystemCollectorTest.java | 4 ++--
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/collector/system/src/main/java/org/apache/karaf/decanter/collector/system/SystemCollector.java b/collector/system/src/main/java/org/apache/karaf/decanter/collector/system/SystemCollector.java
index 5d4fa62..ce64b7d 100644
--- a/collector/system/src/main/java/org/apache/karaf/decanter/collector/system/SystemCollector.java
+++ b/collector/system/src/main/java/org/apache/karaf/decanter/collector/system/SystemCollector.java
@@ -70,7 +70,7 @@ public class SystemCollector implements Runnable {
this.topic = this.topic + "/";
}
try {
- this.threadNumber = context.getProperties().get("thread.number") != null ? Integer.class.cast(context.getProperties().get("thread.number")) : 1;
+ this.threadNumber = context.getProperties().get("thread.number") != null ? Integer.parseInt(String.class.cast(context.getProperties().get("thread.number"))) : 1;
} catch (Exception e) {
throw new IllegalArgumentException("invalid parameter 'thread.number' is not a number");
}
diff --git a/collector/system/src/test/java/org/apache/karaf/decanter/collector/system/SystemCollectorTest.java b/collector/system/src/test/java/org/apache/karaf/decanter/collector/system/SystemCollectorTest.java
index 0f14d0e..08c15fd 100644
--- a/collector/system/src/test/java/org/apache/karaf/decanter/collector/system/SystemCollectorTest.java
+++ b/collector/system/src/test/java/org/apache/karaf/decanter/collector/system/SystemCollectorTest.java
@@ -53,7 +53,7 @@ public class SystemCollectorTest {
this.eventAdmin = new EventAdminStub();
collector.dispatcher = eventAdmin;
componentContext = new ComponentContextStub();
- componentContext.getProperties().put("thread.number", 5);
+ componentContext.getProperties().put("thread.number", "5");
componentContext.getProperties().put("command.df1", "df -h");
componentContext.getProperties().put("command.df2", "df -h");
componentContext.getProperties().put("command.df3", "df -h");
@@ -71,7 +71,7 @@ public class SystemCollectorTest {
this.eventAdmin = new EventAdminStub();
collector.dispatcher = eventAdmin;
componentContext = new ComponentContextStub();
- componentContext.getProperties().put("thread.number", 5);
+ componentContext.getProperties().put("thread.number", "5");
for (int cpt = 0; cpt < 1000; cpt++) {
componentContext.getProperties().put("command.df" + cpt, "df -h");
}