diff --git a/src/explorviz/live_trace_processing/connector/TCPConnector.java b/src/explorviz/live_trace_processing/connector/TCPConnector.java index 5ceb26052a1dd4b6f981dbab5f9cc3a4d9f44669..05d0336854a6159eccba4ff77d789f5f2d765d3d 100644 --- a/src/explorviz/live_trace_processing/connector/TCPConnector.java +++ b/src/explorviz/live_trace_processing/connector/TCPConnector.java @@ -12,7 +12,7 @@ import explorviz.live_trace_processing.StringRegistry; import explorviz.live_trace_processing.configuration.Configuration; import explorviz.live_trace_processing.filter.AbstractSink; import explorviz.live_trace_processing.record.IRecord; -import explorviz.live_trace_processing.record.ISerilizableRecord; +import explorviz.live_trace_processing.record.ISerializableRecord; import explorviz.live_trace_processing.record.misc.StringRegistryRecord; import explorviz.live_trace_processing.record.misc.TerminateRecord; import explorviz.live_trace_processing.record.misc.TimedPeriodRecord; @@ -72,12 +72,12 @@ public class TCPConnector extends AbstractSink implements IWriter, IStringRecord @Override protected void processRecord(final IRecord record) { - if (record instanceof ISerilizableRecord) { - final ISerilizableRecord serilizableRecord = (ISerilizableRecord) record; - if (buffer.remaining() < serilizableRecord.getRecordSizeInBytes()) { + if (record instanceof ISerializableRecord) { + final ISerializableRecord serializableRecord = (ISerializableRecord) record; + if (buffer.remaining() < serializableRecord.getRecordSizeInBytes()) { send(buffer); } - serilizableRecord.putIntoByteBuffer(buffer, stringRegistry); + serializableRecord.putIntoByteBuffer(buffer, stringRegistry); } else if (record instanceof TimedPeriodRecord) { if (buffer.hasRemaining()) { send(buffer);