Neo4jEndpoint extends DefaultEndpoint { @Override public Consumer createConsumer(Processor processor) throws Exception { throw new UnsupportedOperationException(); } Neo4jEndpoint(String endpointUri, String remaining, Neo4jComponent component); @Override Consumer createConsumer(Processor processor); @Override Producer createProducer(); @Override boolean isSingleton(); static final String HEADER_OPERATION; static final String HEADER_NODE_ID; static final String HEADER_RELATIONSHIP_ID; }
@Test(expected = UnsupportedOperationException.class) public void testConsumerUnsupported() throws Exception { new Neo4jEndpoint("ignored", "http: }