public void testConnectorServiceState() throws Exception {
Connector connector = Mockito.mock(Connector.class);
ConnectorService processorService = new MockConnectorService("test", connector, resourceRegistry);
Assert.assertEquals(State.STOPPED, processorService.getState());
processorService.start();
Assert.assertEquals(State.STARTED, processorService.getState());
processorService.stop();
Assert.assertEquals(State.STOPPED, processorService.getState());
}