Skip to content
Snippets Groups Projects
Commit b5b6733b authored by Christian Wulf's avatar Christian Wulf
Browse files

adapted new API

parent 6532808b
Branches
Tags
No related merge requests found
#FindBugs User Preferences #FindBugs User Preferences
#Mon Jun 22 16:34:51 CEST 2015 #Mon Jun 22 16:47:12 CEST 2015
detector_threshold=2 detector_threshold=2
effort=max effort=max
excludefilter0=.fbExcludeFilterFile|true excludefilter0=.fbExcludeFilterFile|true
......
...@@ -11,8 +11,8 @@ import java.util.List; ...@@ -11,8 +11,8 @@ import java.util.List;
import org.junit.Before; import org.junit.Before;
import org.junit.Test; import org.junit.Test;
import teetime.framework.Analysis; import teetime.framework.ConfigurationContext;
import teetime.framework.AnalysisConfiguration; import teetime.framework.Execution;
import teetime.framework.Stage; import teetime.framework.Stage;
import teetime.framework.exceptionHandling.TerminatingExceptionListenerFactory; import teetime.framework.exceptionHandling.TerminatingExceptionListenerFactory;
import teetime.stage.CollectorSink; import teetime.stage.CollectorSink;
...@@ -36,7 +36,7 @@ public class ControlledDistributorTest { ...@@ -36,7 +36,7 @@ public class ControlledDistributorTest {
List<PortAction<Integer>> inputActions = Arrays.asList(createAction, createAction, createAction, createAction, createAction); List<PortAction<Integer>> inputActions = Arrays.asList(createAction, createAction, createAction, createAction, createAction);
ControlledDistributorTestConfig<Integer> config = new ControlledDistributorTestConfig<Integer>(inputNumbers, inputActions); ControlledDistributorTestConfig<Integer> config = new ControlledDistributorTestConfig<Integer>(inputNumbers, inputActions);
Analysis<ControlledDistributorTestConfig<Integer>> analysis = new Analysis<ControlledDistributorTestConfig<Integer>>(config, Execution<ControlledDistributorTestConfig<Integer>> analysis = new Execution<ControlledDistributorTestConfig<Integer>>(config,
new TerminatingExceptionListenerFactory()); new TerminatingExceptionListenerFactory());
analysis.executeBlocking(); analysis.executeBlocking();
...@@ -56,7 +56,7 @@ public class ControlledDistributorTest { ...@@ -56,7 +56,7 @@ public class ControlledDistributorTest {
} }
ControlledDistributorTestConfig<Integer> config = new ControlledDistributorTestConfig<Integer>(inputNumbers, Arrays.asList(inputActions)); ControlledDistributorTestConfig<Integer> config = new ControlledDistributorTestConfig<Integer>(inputNumbers, Arrays.asList(inputActions));
Analysis<ControlledDistributorTestConfig<Integer>> analysis = new Analysis<ControlledDistributorTestConfig<Integer>>(config, Execution<ControlledDistributorTestConfig<Integer>> analysis = new Execution<ControlledDistributorTestConfig<Integer>>(config,
new TerminatingExceptionListenerFactory()); new TerminatingExceptionListenerFactory());
analysis.executeBlocking(); analysis.executeBlocking();
...@@ -83,7 +83,7 @@ public class ControlledDistributorTest { ...@@ -83,7 +83,7 @@ public class ControlledDistributorTest {
inputActions[5] = new RemovePortAction<Integer>(null); inputActions[5] = new RemovePortAction<Integer>(null);
ControlledDistributorTestConfig<Integer> config = new ControlledDistributorTestConfig<Integer>(inputNumbers, Arrays.asList(inputActions)); ControlledDistributorTestConfig<Integer> config = new ControlledDistributorTestConfig<Integer>(inputNumbers, Arrays.asList(inputActions));
Analysis<ControlledDistributorTestConfig<Integer>> analysis = new Analysis<ControlledDistributorTestConfig<Integer>>(config, Execution<ControlledDistributorTestConfig<Integer>> analysis = new Execution<ControlledDistributorTestConfig<Integer>>(config,
new TerminatingExceptionListenerFactory()); new TerminatingExceptionListenerFactory());
analysis.executeBlocking(); analysis.executeBlocking();
...@@ -109,7 +109,7 @@ public class ControlledDistributorTest { ...@@ -109,7 +109,7 @@ public class ControlledDistributorTest {
assertThat(collectorSink.getElements(), is(values)); assertThat(collectorSink.getElements(), is(values));
} }
private static class ControlledDistributorTestConfig<T> extends AnalysisConfiguration { private static class ControlledDistributorTestConfig<T> extends ConfigurationContext {
private final CollectorSink<T> collectorSink; private final CollectorSink<T> collectorSink;
...@@ -121,7 +121,6 @@ public class ControlledDistributorTest { ...@@ -121,7 +121,6 @@ public class ControlledDistributorTest {
connectPorts(initialElementProducer.getOutputPort(), distributor.getInputPort()); connectPorts(initialElementProducer.getOutputPort(), distributor.getInputPort());
connectPorts(distributor.getNewOutputPort(), collectorSink.getInputPort()); connectPorts(distributor.getNewOutputPort(), collectorSink.getInputPort());
addThreadableStage(initialElementProducer);
addThreadableStage(distributor); addThreadableStage(distributor);
addThreadableStage(collectorSink); addThreadableStage(collectorSink);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment