@Override
    public void write(Chunk<? extends I> chunk) throws Exception {
        for (I item : chunk) {
            LOG.debug("writing item [{}]...", item);
            template.sendBody(endpointUri, item);
            LOG.debug("wrote item");
        }
    }
@Test
    public void shouldReadMessage() throws Exception {
        // When
        camelItemWriter.write(Chunk.of(message));

        // Then
        assertEquals(message, consumer().receiveBody("seda:queue"));
    }