@Test
public void testGetSQLQuery() {

	InputStream is = new InputStream();
	StreamSource ss = new StreamSource();
	ss.setAddressing(addressing);
	ss.setAlias("my-stream");
	ss.setRawHistorySize("10m");
	ss.setInputStream(is);
	assertTrue(ss.getSqlQuery().trim().equals("select * from wrapper"));
	ss = new StreamSource();
	ss.setAddressing(addressing);
	ss.setAlias("my-stream");
	ss.setRawHistorySize("10m");
	ss.setSqlQuery(" ");
	ss.setInputStream(is);
	assertEquals(ss.getSqlQuery().trim(),"select * from wrapper");
}