uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateRegistering.java [27:44]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
      CoreInfra infra,
      Node worker,
      ControllerClient.Factory controllerClientFactory,
      Lease lease,
      java.time.Duration heartbeatTimeout,
      ExecutorService commandExecutorService,
      Controllable controllable,
      ControllerClient controllerClient) {
    super(
        loggerPrototype,
        infra.tagged(ImmutableMap.of(MetricsTags.STATE, STATE)),
        worker,
        controllerClientFactory,
        lease,
        heartbeatTimeout,
        commandExecutorService,
        controllable);
    this.controllerClient = controllerClient;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java [50:67]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
      CoreInfra infra,
      Node worker,
      ControllerClient.Factory controllerClientFactory,
      Lease lease,
      java.time.Duration heartbeatTimeout,
      ExecutorService commandExecutorService,
      Controllable controllable,
      ControllerClient controllerClient) {
    super(
        loggerPrototype,
        infra.tagged(ImmutableMap.of(MetricsTags.STATE, STATE)),
        worker,
        controllerClientFactory,
        lease,
        heartbeatTimeout,
        commandExecutorService,
        controllable);
    this.controllerClient = controllerClient;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -