OsgiMulticastEndpoint extends OsgiDefaultEndpoint { @Override public Producer createProducer() throws Exception { return new OsgiMulticastProducer( this, getProps(), getAggregationStrategy(), isParallelProcessing(), getExecutorService(), isShutdownExecutorService(), isStreaming(), isStopOnException(), getTimeout(), getOnPrepare()); } OsgiMulticastEndpoint(String endpointUri, Component component); @Override Consumer createConsumer(Processor processor); @Override Producer createProducer(); AggregationStrategy getAggregationStrategy(); void setAggregationStrategy(AggregationStrategy aggregationStrategy); boolean isParallelProcessing(); void setParallelProcessing(boolean parallelProcessing); ExecutorService getExecutorService(); void setExecutorService(ExecutorService executorService); boolean isShutdownExecutorService(); void setShutdownExecutorService(boolean shutdownExecutorService); boolean isStreaming(); void setStreaming(boolean streaming); boolean isStopOnException(); void setStopOnException(boolean stopOnException); long getTimeout(); void setTimeout(long timeout); Processor getOnPrepare(); void setOnPrepare(Processor onPrepare);  }
@Test public void testCreateProducer() throws Exception { OsgiMulticastEndpoint endpoint = createEndpoint(); assertThat(endpoint.createProducer(), instanceOf(OsgiMulticastProducer.class)); }