@Test
public void testColumnAlreadyExistsInStream() throws Exception {

    String columnName= "myAttr";
    StreamDefinition definition= Mockito.mock(StreamDefinition.class);
    when(definition.getAttributeList()).thenReturn(listAttributes);
    assertTrue("Expected attribute not found", SiddhiUtils.columnAlreadyExistsInStream(columnName, definition));
    assertFalse("Unexpected attribute found", SiddhiUtils.columnAlreadyExistsInStream("NotExists", definition));
}