diff --git a/tap/tcp_reader.go b/tap/tcp_reader.go
index e15ae87db..c39f9b25d 100644
--- a/tap/tcp_reader.go
+++ b/tap/tcp_reader.go
@@ -121,7 +121,7 @@ func (reader *tcpReader) Read(p []byte) (int, error) {
 			if !reader.isProtocolIdentified() {
 				reader.msgBufferMaster = append(
 					reader.msgBufferMaster,
-					msg,
+					NewTcpReaderDataMsg(msg.GetBytes(), msg.GetTimestamp()),
 				)
 			}
 		}