### Question:
TaskDispatcher { public synchronized void startDispatcher() { try { taskExecutor.start(); } catch (DataLayerException e) { throw new IllegalStateException("Could not start task executor", e); } } @Inject  TaskDispatcher(@DataLayer(ConnectionType.CTS_ASYNC) TaskFactory taskFactory,
            @DataLayer(ConnectionType.CTS_ASYNC) TaskExecutor taskExecutor); synchronized void startDispatcher(); void create(Token token, ResultHandler<Token, ?> handler); void read(String tokenId, ResultHandler<Token, ?> handler); void update(Token token, ResultHandler<Token, ?> handler); void delete(String tokenId, ResultHandler<String, ?> handler); void query(TokenFilter tokenFilter, ResultHandler<Collection<Token>, ?> handler); void partialQuery(TokenFilter tokenFilter, ResultHandler<Collection<PartialToken>, ?> handler);  }### Answer:
@Test public void shouldUseConfigurationToInitialise() throws CoreTokenException { queue.startDispatcher(); verify(mockExecutor).start(); }