Repository: apex-core Updated Branches: refs/heads/master 9054fd2b9 -> 869e166e1
APEXCORE-690 apply HEARTBEAT_MONITORING setting in embedded app launcher. Project: http://git-wip-us.apache.org/repos/asf/apex-core/repo Commit: http://git-wip-us.apache.org/repos/asf/apex-core/commit/869e166e Tree: http://git-wip-us.apache.org/repos/asf/apex-core/tree/869e166e Diff: http://git-wip-us.apache.org/repos/asf/apex-core/diff/869e166e Branch: refs/heads/master Commit: 869e166e1c733fc8bfe1acf189f5d9ff7f654fdc Parents: 9054fd2 Author: Thomas Weise <[email protected]> Authored: Wed Apr 5 08:17:26 2017 -0700 Committer: Thomas Weise <[email protected]> Committed: Wed Apr 5 08:17:26 2017 -0700 ---------------------------------------------------------------------- .../java/org/apache/apex/engine/EmbeddedAppLauncherImpl.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/apex-core/blob/869e166e/engine/src/main/java/org/apache/apex/engine/EmbeddedAppLauncherImpl.java ---------------------------------------------------------------------- diff --git a/engine/src/main/java/org/apache/apex/engine/EmbeddedAppLauncherImpl.java b/engine/src/main/java/org/apache/apex/engine/EmbeddedAppLauncherImpl.java index 5930e78..958907d 100644 --- a/engine/src/main/java/org/apache/apex/engine/EmbeddedAppLauncherImpl.java +++ b/engine/src/main/java/org/apache/apex/engine/EmbeddedAppLauncherImpl.java @@ -79,9 +79,7 @@ public class EmbeddedAppLauncherImpl extends LocalMode<EmbeddedAppLauncherImpl.E throw new LauncherException(e); } } - if (StramUtils.getValueWithDefault(launchParameters, HEARTBEAT_MONITORING)) { - lc.setHeartbeatMonitoringEnabled(true); - } + lc.setHeartbeatMonitoringEnabled(StramUtils.getValueWithDefault(launchParameters, HEARTBEAT_MONITORING)); if (StramUtils.getValueWithDefault(launchParameters, RUN_ASYNC)) { lc.runAsync(); launched = true;
