Skip to content
Snippets Groups Projects
Commit 3f45db81 authored by brinn's avatar brinn
Browse files

[DMV-31] ensure the incoming and the local processor thread create the right...

[DMV-31] ensure the incoming and the local processor thread create the right marker file for their successor when they are finished

SVN: 7191
parent d84c5260
No related branches found
No related tags found
No related merge requests found
...@@ -116,12 +116,12 @@ public final class IncomingProcessorTest ...@@ -116,12 +116,12 @@ public final class IncomingProcessorTest
assertEquals("Marker file " + markerFile + " still there", false, markerFile assertEquals("Marker file " + markerFile + " still there", false, markerFile
.exists()); .exists());
} }
public void canceling() public void canceling()
{ {
fail("Invocation of 'canceling()' not expected."); fail("Invocation of 'canceling()' not expected.");
} }
}; };
@BeforeMethod @BeforeMethod
...@@ -134,7 +134,7 @@ public final class IncomingProcessorTest ...@@ -134,7 +134,7 @@ public final class IncomingProcessorTest
mover = context.mock(IPathMover.class); mover = context.mock(IPathMover.class);
remover = context.mock(IPathRemover.class); remover = context.mock(IPathRemover.class);
exitHandler = context.mock(IExitHandler.class); exitHandler = context.mock(IExitHandler.class);
FileUtilities.deleteRecursively(TEST_FOLDER); FileUtilities.deleteRecursively(TEST_FOLDER);
TEST_FOLDER.mkdirs(); TEST_FOLDER.mkdirs();
exampleScript = new File(TEST_FOLDER, EXAMPLE_SCRIPT_NAME); exampleScript = new File(TEST_FOLDER, EXAMPLE_SCRIPT_NAME);
...@@ -220,7 +220,6 @@ public final class IncomingProcessorTest ...@@ -220,7 +220,6 @@ public final class IncomingProcessorTest
assertEquals("", logRecorder.getLogContent()); assertEquals("", logRecorder.getLogContent());
context.assertIsSatisfied(); context.assertIsSatisfied();
} }
@Test @Test
public void testWithDataCompletedScriptWhichFailsInitially() throws IOException public void testWithDataCompletedScriptWhichFailsInitially() throws IOException
...@@ -302,7 +301,7 @@ public final class IncomingProcessorTest ...@@ -302,7 +301,7 @@ public final class IncomingProcessorTest
will(returnValue(remover)); will(returnValue(remover));
} }
}); });
return IncomingProcessor.createMovingProcess(parameters, MARKER_FILE, return IncomingProcessor.createMovingProcess(parameters, MARKER_FILE, null,
fileSysOpertationFactory, new MockTimeProvider(), localBufferDirs); fileSysOpertationFactory, new MockTimeProvider(), localBufferDirs);
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment