@Test public void testCreateConsumer() throws Exception { Processor processor = mock(Processor.class); OsgiDefaultEndpoint endpoint = createEndpoint(); assertThat(endpoint.createConsumer(processor), instanceOf(OsgiDefaultConsumer.class)); }
@Override public Consumer createConsumer(Processor processor) throws Exception { return new OsgiDefaultConsumer(this, processor, getProps()); }
OsgiDefaultEndpoint extends DefaultEndpoint { @Override public Consumer createConsumer(Processor processor) throws Exception { return new OsgiDefaultConsumer(this, processor, getProps()); } }
OsgiDefaultEndpoint extends DefaultEndpoint { @Override public Consumer createConsumer(Processor processor) throws Exception { return new OsgiDefaultConsumer(this, processor, getProps()); } OsgiDefaultEndpoint(String endpointUri, Component component); }
OsgiDefaultEndpoint extends DefaultEndpoint { @Override public Consumer createConsumer(Processor processor) throws Exception { return new OsgiDefaultConsumer(this, processor, getProps()); } OsgiDefaultEndpoint(String endpointUri, Component component); @Override Consumer createConsumer(Processor processor); @Override Producer createProducer(); @Override boolean isSingleton(); @Override OsgiComponent getComponent(); Map<String, Object> getProps(); void setProps(Map<String, Object> props); }
OsgiDefaultEndpoint extends DefaultEndpoint { @Override public Consumer createConsumer(Processor processor) throws Exception { return new OsgiDefaultConsumer(this, processor, getProps()); } OsgiDefaultEndpoint(String endpointUri, Component component); @Override Consumer createConsumer(Processor processor); @Override Producer createProducer(); @Override boolean isSingleton(); @Override OsgiComponent getComponent(); Map<String, Object> getProps(); void setProps(Map<String, Object> props);  }