RCodeEndpoint extends DefaultEndpoint { @Override public Consumer createConsumer(Processor processor) throws Exception { throw new UnsupportedOperationException("Not supported yet."); } RCodeEndpoint();  RCodeEndpoint(String endpointUri, RCodeComponent component);  RCodeEndpoint(String endpointUri, RCodeComponent component, RCodeConfiguration configuration, RCodeOperation operation); @Override Producer createProducer(); @Override Consumer createConsumer(Processor processor); @Override boolean isSingleton(); boolean isConnected(); void reconnect(); REXP sendEval(String command); void sendVoidEval(String command); void sendAssign(String symbol, String content); void sendAssign(String symbol, REXP rexp); REXP sendParseAndEval(String command); RCodeConfiguration getConfiguration(); void setConfiguration(RCodeConfiguration configuration); String getHost(); void setHost(String host); int getPort(); void setPort(int port); String getUser(); void setUser(String user); String getPassword(); void setPassword(String password); long getBufferSize(); void setBufferSize(long bufferSize);  }
@Test(expected = UnsupportedOperationException.class) public void testEmptyConstructor() throws Exception { RCodeEndpoint endpoint = new RCodeEndpoint(); assertNotNull(endpoint); endpoint.createConsumer(new Processor() { @Override public void process(Exchange exchange) throws Exception { } }); }