@Override
    @SuppressWarnings("unchecked")
    public O process(I i) throws Exception {
        LOG.debug("processing item [{}]...", i);
        O result = (O) producerTemplate.requestBody(endpointUri, i);
        LOG.debug("processed item");
        return result;
    }
@Test
    public void shouldReturnDoubledMessage() throws Exception {
        // When
        String messageRead = camelItemProcessor.process(message);

        // Then
        assertEquals(message + message, messageRead);
    }