OsgiDefaultProducer extends DefaultProducer { @Override public void process(Exchange exchange) throws Exception { processor.process(exchange); } OsgiDefaultProducer(OsgiDefaultEndpoint endpoint, Map<String, Object> props); @Override void process(Exchange exchange); @Override OsgiDefaultEndpoint getEndpoint();  }
@Test public void testProcess() throws Exception { Processor processor = mock(Processor.class); OsgiDefaultProducer producer = createProducer(Collections.<String, Object>emptyMap()); producer.processor = processor; Exchange exchange = mock(Exchange.class); producer.process(exchange); verify(processor).process(same(exchange)); }