@Test public void testCreateProcessor() throws Exception { ExecutorService executor = mock(ExecutorService.class); ExecutorServiceManager executorManager = mock(ExecutorServiceManager.class); when(executorManager.newDefaultThreadPool(anyObject(), anyString())).thenReturn(executor); CamelContext camelContext = mock(CamelContext.class); when(camelContext.getExecutorServiceManager()).thenReturn(executorManager); OsgiDefaultEndpoint endpoint = mock(OsgiDefaultEndpoint.class); when(endpoint.getCamelContext()).thenReturn(camelContext); OsgiMulticastProducer producer = new OsgiMulticastProducer( endpoint, Collections.<String, Object>emptyMap(), null, true, null, false, true, true, 1, null); MulticastProcessor processor = (MulticastProcessor) producer.createProcessor(); assertThat(processor.getAggregationStrategy(), nullValue()); assertThat(processor.isParallelProcessing(), equalTo(true)); assertThat(processor.isStreaming(), equalTo(true)); assertThat(processor.isStopOnException(), equalTo(true)); assertThat(processor.getTimeout(), equalTo(1L)); }
@Override protected Processor createProcessor() { return new MulticastProcessor(getEndpoint().getCamelContext(), services, aggregationStrategy, parallelProcessing, executorService, shutdownExecutorService, streaming, stopOnException, timeout, onPrepare, false); }
OsgiMulticastProducer extends OsgiDefaultProducer { @Override protected Processor createProcessor() { return new MulticastProcessor(getEndpoint().getCamelContext(), services, aggregationStrategy, parallelProcessing, executorService, shutdownExecutorService, streaming, stopOnException, timeout, onPrepare, false); } }
OsgiMulticastProducer extends OsgiDefaultProducer { @Override protected Processor createProcessor() { return new MulticastProcessor(getEndpoint().getCamelContext(), services, aggregationStrategy, parallelProcessing, executorService, shutdownExecutorService, streaming, stopOnException, timeout, onPrepare, false); } OsgiMulticastProducer(OsgiDefaultEndpoint endpoint, Map<String, Object> props,
        AggregationStrategy aggregationStrategy, boolean parallelProcessing, ExecutorService executorService,
        boolean shutdownExecutorService, boolean streaming, boolean stopOnException, long timeout,
        Processor onPrepare); }
OsgiMulticastProducer extends OsgiDefaultProducer { @Override protected Processor createProcessor() { return new MulticastProcessor(getEndpoint().getCamelContext(), services, aggregationStrategy, parallelProcessing, executorService, shutdownExecutorService, streaming, stopOnException, timeout, onPrepare, false); } OsgiMulticastProducer(OsgiDefaultEndpoint endpoint, Map<String, Object> props,
        AggregationStrategy aggregationStrategy, boolean parallelProcessing, ExecutorService executorService,
        boolean shutdownExecutorService, boolean streaming, boolean stopOnException, long timeout,
        Processor onPrepare); AggregationStrategy getAggregationStrategy(); boolean isParallelProcessing(); ExecutorService getExecutorService(); boolean isStreaming(); boolean isStopOnException(); long getTimeout(); Processor getOnPrepare(); boolean isDefaultExecutorService(); }
OsgiMulticastProducer extends OsgiDefaultProducer { @Override protected Processor createProcessor() { return new MulticastProcessor(getEndpoint().getCamelContext(), services, aggregationStrategy, parallelProcessing, executorService, shutdownExecutorService, streaming, stopOnException, timeout, onPrepare, false); } OsgiMulticastProducer(OsgiDefaultEndpoint endpoint, Map<String, Object> props,
        AggregationStrategy aggregationStrategy, boolean parallelProcessing, ExecutorService executorService,
        boolean shutdownExecutorService, boolean streaming, boolean stopOnException, long timeout,
        Processor onPrepare); AggregationStrategy getAggregationStrategy(); boolean isParallelProcessing(); ExecutorService getExecutorService(); boolean isStreaming(); boolean isStopOnException(); long getTimeout(); Processor getOnPrepare(); boolean isDefaultExecutorService();  }