Skip to content

Commit

Permalink
[grid] Removing unneeded variable
Browse files Browse the repository at this point in the history
[skip ci]
  • Loading branch information
diemol committed Sep 16, 2021
1 parent 1cdf89c commit 3797357
Showing 1 changed file with 1 addition and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -117,7 +117,6 @@ public class LocalDistributor extends Distributor implements Closeable {
private final Regularly purgeDeadNodes = new Regularly("Purge deadNodes");
private final Map<NodeId, Runnable> allChecks = new HashMap<>();
private final Duration healthcheckInterval;
private final Duration sessionRequestRetryInterval;

private final ReadWriteLock lock = new ReentrantReadWriteLock(/* fair */ true);
private final GridModel model;
Expand Down Expand Up @@ -157,11 +156,10 @@ public LocalDistributor(
this.slotSelector = Require.nonNull("Slot selector", slotSelector);
this.registrationSecret = Require.nonNull("Registration secret", registrationSecret);
this.healthcheckInterval = Require.nonNull("Health check interval", healthcheckInterval);
this.sessionRequestRetryInterval = Require.nonNull("Session request interval",
sessionRequestRetryInterval);
this.model = new GridModel(bus);
this.nodes = new ConcurrentHashMap<>();
this.rejectUnsupportedCaps = rejectUnsupportedCaps;
Require.nonNull("Session request interval", sessionRequestRetryInterval);

bus.addListener(NodeStatusEvent.listener(this::register));
bus.addListener(NodeStatusEvent.listener(model::refresh));
Expand Down

0 comments on commit 3797357

Please sign in to comment.