Plc4XEndpoint extends DefaultEndpoint { @Override public Consumer createConsumer(Processor processor) throws Exception { if (!connection.isConnected()) { try { connection = plcDriverManager.getConnection(uri.replaceFirst("plc4x:/?/?", "")); } catch (Exception e) { e.printStackTrace(); } } return new Plc4XConsumer(this, processor); } Plc4XEndpoint(String endpointUri, Component component); int getPeriod(); void setPeriod(int period); String getUri(); String getTrigger(); void setTrigger(String trigger); PlcConnection getConnection(); @Override void setProperties(Object bean, Map<String, Object> parameters); @Override Producer createProducer(); @Override Consumer createConsumer(Processor processor); @Override PollingConsumer createPollingConsumer(); @Override boolean isSingleton(); PlcDriverManager getPlcDriverManager(); String getDriver(); void setDriver(String driver); Map<String, Object> getTags(); void setTags(Map<String, Object> tags); @Override boolean equals(Object o); @Override int hashCode(); @Override void doStop();  }
@Test public void createConsumer() throws Exception { assertThat(SUT.createConsumer(mock(Processor.class)), notNullValue()); }