You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by mc...@apache.org on 2016/02/02 20:41:58 UTC
nifi git commit: NIFI-1457: - Update heartbeat bean when primary
state changes.
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 <ma...@gmail.com>
Authored: Tue Feb 2 13:16:10 2016 -0500
Committer: Matt Gilman <ma...@gmail.com>
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();
}