Add NetFlow version assertions to NetFlowCodecTest

Author: Jochen Schalanda

src/test/java/org/graylog/plugins/netflow/codecs/NetFlowCodecTest.java

@@ -239,7 +239,9 @@ public void pcap_softflowd_NetFlowV5() throws Exception {
                         return true;
                     }
             );
-            assertThat(allMessages).hasSize(4);
+            assertThat(allMessages)
+                    .hasSize(4)
+                    .allSatisfy(message -> assertThat(message.getField("nf_version")).isEqualTo(5));
         }
     }
 
@@ -261,7 +263,9 @@ public void pcap_pmacctd_NetFlowV5() throws Exception {
                         return true;
                     }
             );
-            assertThat(allMessages).hasSize(42);
+            assertThat(allMessages)
+                    .hasSize(42)
+                    .allSatisfy(message -> assertThat(message.getField("nf_version")).isEqualTo(5));;
         }
     }
 
@@ -284,7 +288,9 @@ public void pcap_softflowd_NetFlowV9() throws Exception {
                     }
             );
         }
-        assertThat(allMessages).hasSize(19);
+        assertThat(allMessages)
+                .hasSize(19)
+                .allSatisfy(message -> assertThat(message.getField("nf_version")).isEqualTo(9));;
     }
 
     @Test
@@ -306,7 +312,9 @@ public void pcap_pmacctd_NetFlowV9() throws Exception {
                     }
             );
         }
-        assertThat(allMessages).hasSize(6);
+        assertThat(allMessages)
+                .hasSize(6)
+                .allSatisfy(message -> assertThat(message.getField("nf_version")).isEqualTo(9));;
     }
 
     @Test