@Test public void testConsume_WithProcDirectory() throws Exception { int count = 1; EmbeddedFtpServer helper = new EmbeddedFtpServer(); MockMessageListener listener = new MockMessageListener(100); FileSystem filesystem = helper.createFilesystem_DirsOnly(); for (int i = 0; i < count; i++) { filesystem.add(new FileEntry(DEFAULT_WORK_DIR_CANONICAL + SLASH + DEFAULT_FILENAME + i + ".txt", PAYLOAD)); } FakeFtpServer server = helper.createAndStart(filesystem); StandaloneConsumer sc = null; try { FtpConsumer ftpConsumer = createForTests(listener, "testConsume_WithProcDirectory"); ftpConsumer.setProcDirectory(DEFAULT_PROC_DIR_CANONICAL); FtpConnection consumeConnection = create(server); sc = new StandaloneConsumer(consumeConnection, ftpConsumer); start(sc); waitForMessages(listener, count); Thread.sleep(500); helper.assertMessages(listener.getMessages(), count); } catch (Exception e) { throw e; } finally { stop(sc); server.stop(); } }
public void setProcDirectory(String s) { procDirectory = s; }
FtpConsumer extends FtpConsumerImpl { public void setProcDirectory(String s) { procDirectory = s; } }
FtpConsumer extends FtpConsumerImpl { public void setProcDirectory(String s) { procDirectory = s; } FtpConsumer(); }
FtpConsumer extends FtpConsumerImpl { public void setProcDirectory(String s) { procDirectory = s; } FtpConsumer(); @Override void init(); String getProcDirectory(); String getWorkDirectory(); void setProcDirectory(String s); void setWorkDirectory(String s); String getWipSuffix(); void setWipSuffix(String s); }
FtpConsumer extends FtpConsumerImpl { public void setProcDirectory(String s) { procDirectory = s; } FtpConsumer(); @Override void init(); String getProcDirectory(); String getWorkDirectory(); void setProcDirectory(String s); void setWorkDirectory(String s); String getWipSuffix(); void setWipSuffix(String s);  }