@Test(expected = UnsupportedOperationException.class) public void testCreateConsumer() throws Exception { OsgiMulticastEndpoint endpoint = createEndpoint(); Processor processor = mock(Processor.class); endpoint.createConsumer(processor); }
@Override public Consumer createConsumer(Processor processor) throws Exception { throw new UnsupportedOperationException( String.format("[%s] does not support consumers. Use [%s] instead.", getClass().getName(), getClass().getSuperclass().getName())); }
OsgiMulticastEndpoint extends OsgiDefaultEndpoint { @Override public Consumer createConsumer(Processor processor) throws Exception { throw new UnsupportedOperationException( String.format("[%s] does not support consumers. Use [%s] instead.", getClass().getName(), getClass().getSuperclass().getName())); } }
OsgiMulticastEndpoint extends OsgiDefaultEndpoint { @Override public Consumer createConsumer(Processor processor) throws Exception { throw new UnsupportedOperationException( String.format("[%s] does not support consumers. Use [%s] instead.", getClass().getName(), getClass().getSuperclass().getName())); } OsgiMulticastEndpoint(String endpointUri, Component component); }
OsgiMulticastEndpoint extends OsgiDefaultEndpoint { @Override public Consumer createConsumer(Processor processor) throws Exception { throw new UnsupportedOperationException( String.format("[%s] does not support consumers. Use [%s] instead.", getClass().getName(), getClass().getSuperclass().getName())); } 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); }
OsgiMulticastEndpoint extends OsgiDefaultEndpoint { @Override public Consumer createConsumer(Processor processor) throws Exception { throw new UnsupportedOperationException( String.format("[%s] does not support consumers. Use [%s] instead.", getClass().getName(), getClass().getSuperclass().getName())); } 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);  }