@Test
public void testConcurrencySafeQueryForObject() throws Exception {

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