diff --git a/pantheon/src/main/java/tech/pegasys/pantheon/controller/IbftPantheonController.java b/pantheon/src/main/java/tech/pegasys/pantheon/controller/IbftPantheonController.java index 9aac539eb5..ae272b75c6 100644 --- a/pantheon/src/main/java/tech/pegasys/pantheon/controller/IbftPantheonController.java +++ b/pantheon/src/main/java/tech/pegasys/pantheon/controller/IbftPantheonController.java @@ -94,6 +94,7 @@ public class IbftPantheonController implements PantheonController { private final IbftProtocolManager ibftProtocolManager; private final KeyPair keyPair; private final TransactionPool transactionPool; + private MiningCoordinator ibftMiningCoordinator; private final Runnable closer; IbftPantheonController( @@ -105,8 +106,8 @@ public class IbftPantheonController implements PantheonController { final Synchronizer synchronizer, final KeyPair keyPair, final TransactionPool transactionPool, + final MiningCoordinator ibftMiningCoordinator, final Runnable closer) { - this.protocolSchedule = protocolSchedule; this.context = context; this.ethSubProtocol = ethSubProtocol; @@ -115,6 +116,7 @@ public class IbftPantheonController implements PantheonController { this.synchronizer = synchronizer; this.keyPair = keyPair; this.transactionPool = transactionPool; + this.ibftMiningCoordinator = ibftMiningCoordinator; this.closer = closer; } @@ -284,6 +286,7 @@ public static PantheonController init( synchronizer, nodeKeys, transactionPool, + ibftMiningCoordinator, closer); } @@ -321,7 +324,7 @@ public TransactionPool getTransactionPool() { @Override public MiningCoordinator getMiningCoordinator() { - return null; + return ibftMiningCoordinator; } @Override