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