@Test
public void testConcurrencyUnsafeQueryForObject() throws Exception {

    SampleEvent event = new SampleEvent();
    template.sendEvent(event);
    SampleEvent result = statement.concurrentUnsafeQueryForObject(this.rowMapper);
    assertEquals(result, event);
}