OsgiRoundRobinEndpoint extends OsgiDefaultEndpoint { @Override public Producer createProducer() throws Exception { return new OsgiRoundRobinProducer(this, getProps()); } OsgiRoundRobinEndpoint(String endpointUri, Component component); @Override Consumer createConsumer(Processor processor); @Override Producer createProducer();  }
@Test public void testCreateProducer() throws Exception { OsgiRoundRobinEndpoint endpoint = createEndpoint(); assertThat(endpoint.createProducer(), instanceOf(OsgiRoundRobinProducer.class)); }