@@ -0,0 +1,541 @@
+package org.apache.storm.flux;%0A%0Aimport org.junit.Test;%0A%0Apublic class IntegrationTest %7B%0A%0A    private static boolean skipTest = true;%0A%0A    static %7B%0A        String skipStr = System.getProperty(%22skipIntegration%22);%0A        if(skipStr != null && skipStr.equalsIgnoreCase(%22false%22))%7B%0A            skipTest = false;%0A        %7D%0A    %7D%0A%0A%0A%0A    @Test%0A    public void testRunTopologySource() throws Exception %7B%0A        if(!skipTest) %7B%0A            Flux.main(new String%5B%5D%7B%22-s%22, %2230000%22, %22src/test/resources/configs/existing-topology.yaml%22%7D);%0A        %7D%0A    %7D%0A%7D%0A

add integration test that runs Flux.main()