Added extra unit tests

Extra unit tests to verify high sequence logic

Fixes #342

Author: robbavey

src/test/java/org/logstash/beats/V1BatchTest.java

@@ -61,6 +61,20 @@ public void testCompleteBatchWithSequenceNumbersNotStartingAtOne(){
         assertTrue(batch.isComplete());
     }
 
+
+    @Test
+    public void testHighSequence(){
+        int numberOfEvent = 2;
+        int startSequenceNumber = new SecureRandom().nextInt(10000);
+        batch.setBatchSize(numberOfEvent);
+
+        for(int i = 1; i <= numberOfEvent; i++) {
+            batch.addMessage(new Message(startSequenceNumber + i, new HashMap()));
+        }
+
+        assertEquals(startSequenceNumber + numberOfEvent, batch.getHighestSequence());
+    }
+
     @Test
     public void TestCompleteReturnWhenTheNumberOfEventDoesntMatchBatchSize() {
         int numberOfEvent = 2;

src/test/java/org/logstash/beats/V2BatchTest.java

@@ -7,6 +7,7 @@
 import io.netty.buffer.Unpooled;
 import org.junit.Test;
 
+import java.security.SecureRandom;
 import java.util.HashMap;
 import java.util.Map;
 
@@ -75,6 +76,21 @@ public void testBigBatch() {
         }
     }
 
+    @Test
+    public void testHighSequence(){
+        V2Batch batch = new V2Batch();
+        int numberOfEvent = 2;
+        int startSequenceNumber = new SecureRandom().nextInt(10000);
+        batch.setBatchSize(numberOfEvent);
+        ByteBuf content = messageContents();
+
+        for(int i = 1; i <= numberOfEvent; i++) {
+            batch.addMessage(startSequenceNumber + i, content, content.readableBytes());
+        }
+
+        assertEquals(startSequenceNumber + numberOfEvent, batch.getHighestSequence());
+    }
+
 
     @Test
     public void TestCompleteReturnWhenTheNumberOfEventDoesntMatchBatchSize() {