adapted new API

.settings/edu.umd.cs.findbugs.core.prefs

 #FindBugs User Preferences
-#Fri Dec 05 08:18:05 CET 2014
+#Fri Dec 05 15:14:55 CET 2014
 detector_threshold=3
 effort=max
 excludefilter0=.fbExcludeFilterFile|true

src/main/java/teetime/stage/className/ClassNameRegistryCreationFilter.java

@@ -61,7 +61,7 @@ public class ClassNameRegistryCreationFilter extends AbstractConsumerStage<File>
 		try {
 			final ClassNameRegistry classNameRegistry = this.mappingFileParser.parseFromStream(new FileInputStream(mappingFile));
 			this.classNameRegistryRepository.put(inputDir, classNameRegistry);
-			this.send(this.outputPort, inputDir);
+			outputPort.send(inputDir);
 
 			// final String filePrefix = this.mappingFileParser.getFilePrefixFromMappingFile(mappingFile);
 			// context.put(this.filePrefixOutputPort, filePrefix); // TODO pass prefix

src/main/java/teetime/stage/explorviz/KiekerRecordTcpReader.java

@@ -181,7 +181,7 @@ public class KiekerRecordTcpReader extends AbstractProducerStage<IMonitoringReco
 		}
 
 		final IMonitoringRecord record = new BeforeOperationEvent(timestamp, traceId, orderIndex, operation, clazz);
-		this.send(this.outputPort, record);
+		outputPort.send(record);
 	}
 
 	private final void readInAfterOperationEvent(final ByteBuffer buffer) {
@@ -190,7 +190,7 @@ public class KiekerRecordTcpReader extends AbstractProducerStage<IMonitoringReco
 		final int orderIndex = buffer.getInt();
 
 		final IMonitoringRecord record = new AfterOperationEvent(timestamp, traceId, orderIndex, null, null);
-		this.send(this.outputPort, record);
+		outputPort.send(record);
 	}
 
 	private final void putInWaitingMessages(final ByteBuffer buffer, final int length) {

src/main/java/teetime/stage/io/database/DbReader.java

@@ -173,7 +173,7 @@ public class DbReader extends AbstractProducerStage<IMonitoringRecord> {
 					}
 					final IMonitoringRecord record = AbstractMonitoringRecord.createFromArray(clazz, recordValues);
 					record.setLoggingTimestamp(records.getLong(2));
-					this.send(this.outputPort, record);
+					outputPort.send(record);
 				}
 			} finally {
 				if (records != null) {

src/main/java/teetime/stage/io/filesystem/format/binary/file/BinaryFile2RecordFilter.java

@@ -79,7 +79,7 @@ public class BinaryFile2RecordFilter extends AbstractConsumerStage<File> {
 			try {
 				IMonitoringRecord record = this.recordFromBinaryFileCreator.createRecordFromBinaryFile(binaryFile, in);
 				while (record != null) {
-					this.send(this.outputPort, record);
+					outputPort.send(record);
 					record = this.recordFromBinaryFileCreator.createRecordFromBinaryFile(binaryFile, in);
 				}
 			} catch (final MonitoringRecordException e) {

src/main/java/teetime/stage/io/filesystem/format/text/file/TextLine2RecordFilter.java

@@ -81,7 +81,7 @@ public class TextLine2RecordFilter extends AbstractConsumerStage<TextLine> {
 	protected void execute(final TextLine textLine) {
 		try {
 			final IMonitoringRecord record = this.recordFromTextLineCreator.createRecordFromLine(textLine.getTextFile(), textLine.getTextLine());
-			this.send(this.outputPort, record);
+			outputPort.send(record);
 		} catch (final MonitoringRecordException e) {
 			this.logger.error("Could not create record from text line: '" + textLine + "'", e);
 		} catch (final IllegalRecordFormatException e) {

src/main/java/teetime/stage/io/network/TcpReader.java

@@ -85,7 +85,7 @@ public class TcpReader extends AbstractTcpReader<IMonitoringRecord> {
 			IMonitoringRecord record = recordFactory.create(buffer, this.stringRegistry);
 			record.setLoggingTimestamp(loggingTimestamp);
 
-			this.send(this.outputPort, record);
+			outputPort.send(record);
 		} catch (final BufferUnderflowException ex) {
 			super.logger.error("Failed to create record.", ex);
 		} catch (final RecordInstantiationException ex) {

src/main/java/teetime/stage/stringBuffer/StringBufferFilter.java

@@ -40,7 +40,7 @@ public class StringBufferFilter<T> extends AbstractConsumerStage<T> {
 	@Override
 	protected void execute(final T element) {
 		final T returnedElement = this.handle(element);
-		this.send(this.outputPort, returnedElement);
+		outputPort.send(returnedElement);
 	}
 
 	@Override

src/main/java/teetime/stage/trace/traceReconstruction/TraceReconstructionFilter.java

@@ -105,7 +105,7 @@ public class TraceReconstructionFilter extends AbstractConsumerStage<IFlowRecord
 	private void sendTraceBuffer(final TraceBuffer traceBuffer) {
 		OutputPort<TraceEventRecords> outputPort = (traceBuffer.isInvalid()) ? this.traceInvalidOutputPort
 				: this.traceValidOutputPort;
-		this.send(outputPort, traceBuffer.toTraceEvents());
+		outputPort.send(traceBuffer.toTraceEvents());
 	}
 
 	public TimeUnit getTimeunit() {

src/main/java/teetime/stage/trace/traceReduction/TraceReductionFilter.java

@@ -79,7 +79,7 @@ public class TraceReductionFilter extends AbstractConsumerStage<TraceEventRecord
 				final TraceAggregationBuffer buffer = entry.getValue();
 				final TraceEventRecords record = buffer.getTraceEventRecords();
 				record.setCount(buffer.getCount());
-				this.send(this.outputPort, record);
+				outputPort.send(record);
 			}
 			this.trace2buffer.clear();
 		}
@@ -97,7 +97,7 @@ public class TraceReductionFilter extends AbstractConsumerStage<TraceEventRecord
 				if (traceBuffer.getBufferCreatedTimestamp() <= bufferTimeoutInNs) {
 					final TraceEventRecords record = traceBuffer.getTraceEventRecords();
 					record.setCount(traceBuffer.getCount());
-					this.send(this.outputPort, record);
+					outputPort.send(record);
 				}
 				iterator.remove();
 			}