diff --git a/jpo-ode-svcs/src/main/java/us/dot/its/jpo/ode/importer/parser/PayloadParser.java b/jpo-ode-svcs/src/main/java/us/dot/its/jpo/ode/importer/parser/PayloadParser.java index d9b2a001f..2436c3025 100644 --- a/jpo-ode-svcs/src/main/java/us/dot/its/jpo/ode/importer/parser/PayloadParser.java +++ b/jpo-ode-svcs/src/main/java/us/dot/its/jpo/ode/importer/parser/PayloadParser.java @@ -111,7 +111,7 @@ public void writeTo(OutputStream os) throws IOException { } - + // Removes the 1609.2 header but will keep the 1609.1 header public byte[] removeHeader(byte[] packet) { String hexPacket = HexUtils.toHexString(packet); String hexPacketParsed = ""; @@ -122,7 +122,7 @@ public byte[] removeHeader(byte[] packet) { logger.debug("Start index for: " + key + " is: " + startIndex); if (startIndex == -1) { logger.debug("Message does not have header for: " + key); - break; + continue; } else if (startIndex <= HEADER_SIZE_1609) { logger.debug("Message has supported header. startIndex: " + startIndex + " msgFlag: " + startFlag); hexPacketParsed = hexPacket;