public synchronized void connect() {
        for (InputHandler inputHandler : inputHandlerMap.values()) {
            inputHandler.connect();
        }
        this.isConnected = true;
    }
Manager class to handle {@link Event} insertion to Siddhi.
modules/siddhi-core/src/main/java/io/siddhi/core/stream/input/InputManager.java