@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);
}