@Override
    @SuppressWarnings("unchecked")
    public I read() throws Exception {
        LOG.debug("reading new item...");
        I item = (I) consumerTemplate.receiveBody(endpointUri);
        LOG.debug("read item [{}]", item);
        return item;
    }
@Test
    public void shouldReadMessage() throws Exception {
        // When
        String messageRead = camelItemReader.read();

        // Then
        assertEquals(message, messageRead);
    }