@Override
    public Consumer createConsumer(Processor processor) throws Exception {
        throw new RuntimeCamelException("Cannot consume from " + getClass().getSimpleName() + ": " + getEndpointUri());
    }
@Test
    public void testCreateConsumer() {
        assertThrows(RuntimeCamelException.class,
                () -> endpoint.createConsumer(processor));
    }