code reformating and added test case

Author: ankit-splunk

src/main/java/com/splunk/hecclient/EventBatch.java

@@ -43,17 +43,14 @@ public abstract class EventBatch {
     protected List<Event> events = new ArrayList<>();
 
     public abstract String getRestEndpoint();
-
     public abstract String getContentType();
-
     public abstract void add(Event event);
-
     public abstract EventBatch createFromThis();
 
     public final void addExtraFields(final Map<String, String> fields) {
         // recalculate the batch length since we inject more meta data to each event
         int newLength = 0;
-        for (final Event event : events) {
+        for (final Event event: events) {
             event.addFields(fields);
             newLength += event.length();
         }
@@ -139,7 +136,7 @@ public final HttpEntity getHttpEntityTemplate() {
     public final String toString() {
         StringBuilder builder = new StringBuilder();
         builder.append("[");
-        for (Event e : events) {
+        for (Event e: events) {
             builder.append(e.toString());
             builder.append(",");
         }

src/test/java/com/splunk/hecclient/IndexerTest.java

@@ -216,4 +216,26 @@ public void sendCompressedBatchWithSuccess() {
             Assert.assertEquals(CloseableHttpClientMock.success, poller.getResponse());
         }
     }
+
+    @Test
+    public void sendCompressedRawBatchWithSuccess() {
+        for (int i = 0; i < 2; i++) {
+            CloseableHttpClientMock client = new CloseableHttpClientMock();
+            if (i == 0) {
+                client.setResponse(CloseableHttpClientMock.success);
+            }
+            PollerMock poller = new PollerMock();
+
+            Indexer indexer = new Indexer(baseUrl, token, client, poller);
+            EventBatch batch = UnitUtil.createRawEventBatch();
+            batch.setEnableCompression(true);
+            boolean result = indexer.send(batch);
+            Assert.assertTrue(result);
+            Assert.assertNotNull(poller.getBatch());
+            Assert.assertNull(poller.getFailedBatch());
+            Assert.assertNull(poller.getException());
+            Assert.assertEquals(indexer.getChannel(), poller.getChannel());
+            Assert.assertEquals(CloseableHttpClientMock.success, poller.getResponse());
+        }
+    }
 }

src/test/java/com/splunk/hecclient/UnitUtil.java

@@ -34,6 +34,13 @@ public static EventBatch createBatch() {
         return batch;
     }
 
+    public static EventBatch createRawEventBatch() {
+        Event event = new RawEvent("ni", "hao");
+        EventBatch batch = RawEventBatch.factory().build();
+        batch.add(event);
+        return batch;
+    }
+
     public static void milliSleep(long milliseconds) {
         try {
             TimeUnit.MILLISECONDS.sleep(milliseconds);