EmptyDatastoreVerifierProcess implements Process { @Override public Map<String, PortType> getInputPorts() { return ports.getInput(); } EmptyDatastoreVerifierProcess(); @Override Map<String, PortType> getInputPorts(); @Override Map<String, PortType> getOutputPorts(); @Override void run(PortBindings portBindings, Configuration conf, Map<String, String> parameters); static final String INPUT_PORT_NAME; static final String DEFAULT_ENCODING; static final String OUTPUT_PROPERTY_IS_EMPTY; }
@Test public void testGetInputPorts() { assertNotNull(process.getInputPorts()); assertEquals(1, process.getInputPorts().size()); assertNotNull(process.getInputPorts().get(EmptyDatastoreVerifierProcess.INPUT_PORT_NAME)); assertEquals(AnyPortType.class, process.getInputPorts().get(EmptyDatastoreVerifierProcess.INPUT_PORT_NAME).getClass()); }