@Test public void testCreateProcessor() throws Exception { CamelContext camelContext = mock(CamelContext.class); OsgiRoundRobinEndpoint endpoint = mock(OsgiRoundRobinEndpoint.class); when(endpoint.getCamelContext()).thenReturn(camelContext); OsgiRoundRobinProducer producer = new OsgiRoundRobinProducer(endpoint, Collections.<String, Object>emptyMap()); assertThat(producer.createProcessor(), instanceOf(RoundRobinLoadBalancer.class)); }
@Override protected Processor createProcessor() { return new RoundRobinLoadBalancer() { @Override public List<Processor> getProcessors() { return services; } }; }
OsgiRoundRobinProducer extends OsgiDefaultProducer { @Override protected Processor createProcessor() { return new RoundRobinLoadBalancer() { @Override public List<Processor> getProcessors() { return services; } }; } }
OsgiRoundRobinProducer extends OsgiDefaultProducer { @Override protected Processor createProcessor() { return new RoundRobinLoadBalancer() { @Override public List<Processor> getProcessors() { return services; } }; } OsgiRoundRobinProducer(OsgiDefaultEndpoint endpoint, Map<String, Object> props); }
OsgiRoundRobinProducer extends OsgiDefaultProducer { @Override protected Processor createProcessor() { return new RoundRobinLoadBalancer() { @Override public List<Processor> getProcessors() { return services; } }; } OsgiRoundRobinProducer(OsgiDefaultEndpoint endpoint, Map<String, Object> props);  }
OsgiRoundRobinProducer extends OsgiDefaultProducer { @Override protected Processor createProcessor() { return new RoundRobinLoadBalancer() { @Override public List<Processor> getProcessors() { return services; } }; } OsgiRoundRobinProducer(OsgiDefaultEndpoint endpoint, Map<String, Object> props);   }