@Test(expected=RestException.class)
public void addInvalid() throws RestException {

    SiddhiHandler siddhiHandler = new SiddhiHandler();
    // Add an execution plan with id testID
    Map<String, Object> executionPlanMap = new HashMap<>();
    Map<String, String> outputTopics = new HashMap<>();
    outputTopics.put("testOutput", "outputTopic");
    executionPlanMap.put("id", "testID");
    executionPlanMap.put("input", Arrays.asList("test", "test2"));
    executionPlanMap.put("output", outputTopics);
    executionPlanMap.put("executionPlan", "from test select **ERROR** insert into testOutput");
    // Try to add the execution plan
    siddhiHandler.add(executionPlanMap);
}