NIFI-1457:

- Update heartbeat bean when primary state changes.
This commit is contained in:
Matt Gilman 2016-02-02 13:16:10 -05:00
parent 77ab5d3684
commit 8cf34c3ea5
1 changed files with 3 additions and 0 deletions

View File

@ -3108,6 +3108,9 @@ public class FlowController implements EventAccess, ControllerServiceProvider, R
// update primary // update primary
this.primary = primary; this.primary = primary;
eventDrivenWorkerQueue.setPrimary(primary); eventDrivenWorkerQueue.setPrimary(primary);
// update the heartbeat bean
this.heartbeatBeanRef.set(new HeartbeatBean(rootGroup, primary, connected));
} finally { } finally {
rwLock.writeLock().unlock(); rwLock.writeLock().unlock();
} }