JmsSinkConnector extends SinkConnector { public void start(Map<String, String> map) { logger.info("operation=start properties={}", map); ApplicationContextHolder.startApplicationContext(map); }  String version(); static String getVersion(Class<?> aClass); void start(Map<String, String> map); Class<? extends Task> taskClass(); List<Map<String, String>> taskConfigs(int i); void stop();  }
@Test public void start() throws Exception { JmsSinkConnector connector = new JmsSinkConnector(); connector.start(testProperties); TestProperties testProperties = ApplicationContextHolder.getApplicationContext().getBean(TestProperties.class); Assert.assertEquals(testProperties.getName(), TEST); connector.stop(); }