class SiddhiHandler implements RestListener, EventHandler<MapEvent> {

    @Override
    public void onEvent(MapEvent mapEvent, long sequence, boolean endOfBatch) throws Exception {
        if (!siddhiPlans.isEmpty()) {
            Map<String, Object> data = mapEvent.getData();
            String topic = mapEvent.getSource();

            for (SiddhiPlan siddhiPlan : siddhiPlans.values()) {
                if (siddhiPlan.getInput().contains(topic)) {
                    siddhiPlan.send(topic, data);
                }
            }
        }
    }

    public  SiddhiHandler(Sink eventReceiver);
    public  SiddhiHandler();

}