diff --git a/pantheon/src/main/java/tech/pegasys/pantheon/controller/CliquePantheonController.java b/pantheon/src/main/java/tech/pegasys/pantheon/controller/CliquePantheonController.java index bbf6445dca..920aff16d2 100644 --- a/pantheon/src/main/java/tech/pegasys/pantheon/controller/CliquePantheonController.java +++ b/pantheon/src/main/java/tech/pegasys/pantheon/controller/CliquePantheonController.java @@ -74,6 +74,7 @@ public class CliquePantheonController private static final long EPOCH_LENGTH_DEFAULT = 30_000L; private static final long SECONDS_BETWEEN_BLOCKS_DEFAULT = 15L; + private final CliqueMiningCoordinator miningCoordinator; CliquePantheonController( final GenesisConfig genesisConfig, @@ -82,6 +83,7 @@ public class CliquePantheonController final Synchronizer synchronizer, final KeyPair keyPair, final TransactionPool transactionPool, + final CliqueMiningCoordinator miningCoordinator, final Runnable closer) { this.genesisConfig = genesisConfig; @@ -91,6 +93,7 @@ public class CliquePantheonController this.keyPair = keyPair; this.transactionPool = transactionPool; this.closer = closer; + this.miningCoordinator = miningCoordinator; } public static PantheonController init( @@ -174,6 +177,7 @@ public class CliquePantheonController synchronizer, nodeKeys, transactionPool, + miningCoordinator, () -> { miningCoordinator.disable(); minerThreadPool.shutdownNow(); @@ -218,7 +222,7 @@ public class CliquePantheonController @Override public AbstractMiningCoordinator getMiningCoordinator() { - return null; + return miningCoordinator; } @Override