Repository: nifi Updated Branches: refs/heads/master 77ab5d368 -> 8cf34c3ea
NIFI-1457: - Update heartbeat bean when primary state changes. Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/8cf34c3e Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/8cf34c3e Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/8cf34c3e Branch: refs/heads/master Commit: 8cf34c3ea5a86a18d3bc7496be7319df0b051999 Parents: 77ab5d3 Author: Matt Gilman <[email protected]> Authored: Tue Feb 2 13:16:10 2016 -0500 Committer: Matt Gilman <[email protected]> Committed: Tue Feb 2 13:16:10 2016 -0500 ---------------------------------------------------------------------- .../src/main/java/org/apache/nifi/controller/FlowController.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/8cf34c3e/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java index 04b48dd..840df94 100644 --- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java +++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java @@ -3108,6 +3108,9 @@ public class FlowController implements EventAccess, ControllerServiceProvider, R // update primary this.primary = primary; eventDrivenWorkerQueue.setPrimary(primary); + + // update the heartbeat bean + this.heartbeatBeanRef.set(new HeartbeatBean(rootGroup, primary, connected)); } finally { rwLock.writeLock().unlock(); }
