@Test
    public void callbackTestForValidEvents() throws Exception {
        log.info("callback test without exception handler");
        SiddhiAppRuntime siddhiAppRuntime = createTestExecutionRuntime();
        InputHandler inputHandler = siddhiAppRuntime.getInputHandler("StockStream");
        siddhiAppRuntime.start();

        sendTestValidEvents(inputHandler);

        SiddhiTestHelper.waitForEvents(100, 6, count, 60000);

        AssertJUnit.assertTrue(eventArrived);
        AssertJUnit.assertEquals(6, count.get());
        AssertJUnit.assertFalse(failedCaught);
        AssertJUnit.assertEquals(0, failedCount.get());
        siddhiAppRuntime.shutdown();
    }
Send 6 test events (2 valid -> 2 invalid -> 2 valid)

@param inputHandler input handler
@throws Exception
modules/siddhi-core/src/test/java/io/siddhi/core/stream/ExceptionHandlerTestCase.java