Skip to content
Snippets Groups Projects
Commit 3463dbe0 authored by Nelson Tavares de Sousa's avatar Nelson Tavares de Sousa
Browse files

adopted new API

parent 632f88ad
Branches
Tags
No related merge requests found
...@@ -43,9 +43,5 @@ public class OldPipeline<FirstStage extends Stage, LastStage extends Stage> exte ...@@ -43,9 +43,5 @@ public class OldPipeline<FirstStage extends Stage, LastStage extends Stage> exte
return lastStages.get(0); return lastStages.get(0);
} }
@Override
protected Collection<? extends Stage> getLastStages() {
return lastStages;
}
} }
...@@ -28,7 +28,6 @@ import teetime.framework.pipe.PipeFactoryRegistry; ...@@ -28,7 +28,6 @@ import teetime.framework.pipe.PipeFactoryRegistry;
import teetime.framework.pipe.PipeFactoryRegistry.PipeOrdering; import teetime.framework.pipe.PipeFactoryRegistry.PipeOrdering;
import teetime.framework.pipe.PipeFactoryRegistry.ThreadCommunication; import teetime.framework.pipe.PipeFactoryRegistry.ThreadCommunication;
import teetime.stage.ObjectProducer; import teetime.stage.ObjectProducer;
import teetime.stage.PortTypeConfiguration;
import teetime.stage.StartTimestampFilter; import teetime.stage.StartTimestampFilter;
import teetime.stage.StopTimestampFilter; import teetime.stage.StopTimestampFilter;
import teetime.stage.basic.Sink; import teetime.stage.basic.Sink;
...@@ -93,11 +92,11 @@ public class ConnectionTypeTest { ...@@ -93,11 +92,11 @@ public class ConnectionTypeTest {
// } // }
assertNull(objectProducer.getOutputPort().getType()); assertNull(objectProducer.getOutputPort().getType());
PortTypeConfiguration.setPortTypes(objectProducer, Class.forName(TimestampObject.class.getName())); // PortTypeConfiguration.setPortTypes(objectProducer, Class.forName(TimestampObject.class.getName()));
assertEquals(TimestampObject.class, objectProducer.getOutputPort().getType()); assertEquals(TimestampObject.class, objectProducer.getOutputPort().getType());
assertNull(startTimestampFilter.getOutputPort().getType()); assertNull(startTimestampFilter.getOutputPort().getType());
PortTypeConfiguration.setPortTypes(startTimestampFilter); // PortTypeConfiguration.setPortTypes(startTimestampFilter);
assertEquals(TimestampObject.class, startTimestampFilter.getInputPort().getType()); assertEquals(TimestampObject.class, startTimestampFilter.getInputPort().getType());
assertEquals(TimestampObject.class, startTimestampFilter.getOutputPort().getType()); assertEquals(TimestampObject.class, startTimestampFilter.getOutputPort().getType());
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment