@Test
public void testConcurrencyUnsafeQuery() throws Exception {

    SampleEvent event = new SampleEvent();
    template.sendEvent(event);
    List<SampleEvent> events = statement.concurrentUnsafeQuery(this.rowMapper);
    assertEquals(events.size(), 1);
    assertEquals(events.get(0), event);
}