Event queue test fixes

Signed-off-by: Matthew Whitehead <[email protected]>

consensus/common/src/test/java/org/hyperledger/besu/consensus/common/bft/BftProcessorTest.java

@@ -130,6 +130,7 @@ public void handlesQueueInterruptGracefully() throws InterruptedException {
   @Test
   public void drainEventsIntoStateMachine() throws InterruptedException {
     final BftEventQueue queue = new BftEventQueue(1000);
+    queue.start();
     final BftProcessor processor = new BftProcessor(queue, mockeEventMultiplexer);
 
     // Start the BftProcessor

consensus/common/src/test/java/org/hyperledger/besu/consensus/common/bft/RoundTimerTest.java

@@ -45,6 +45,7 @@ public class RoundTimerTest {
   public void initialise() {
     bftExecutors = mock(BftExecutors.class);
     queue = new BftEventQueue(1000);
+    queue.start();
     timer = new RoundTimer(queue, 1, bftExecutors);
   }
 

consensus/common/src/test/java/org/hyperledger/besu/consensus/common/bft/blockcreation/BftMiningCoordinatorTest.java

@@ -56,6 +56,7 @@ public class BftMiningCoordinatorTest {
 
   @BeforeEach
   public void setup() {
+    eventQueue.start();
     bftMiningCoordinator =
         new BftMiningCoordinator(
             bftExecutors, controller, bftProcessor, bftBlockCreatorFactory, blockChain, eventQueue);