From 9cf71380e174646fdae77cf19bd9933b7b73afd3 Mon Sep 17 00:00:00 2001
From: Deklan Dieterly <deklan.dieterly@hp.com>
Date: Fri, 7 Mar 2014 17:21:46 -0700
Subject: [PATCH] Make commit always flush.

---
 .../com/hpcloud/disruptor/event/MetricMessageEventHandler.java  | 2 +-
 .../java/com/hpcloud/repository/VerticaMetricRepository.java    | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/hpcloud/disruptor/event/MetricMessageEventHandler.java b/src/main/java/com/hpcloud/disruptor/event/MetricMessageEventHandler.java
index 8b763e43..8d5231c5 100644
--- a/src/main/java/com/hpcloud/disruptor/event/MetricMessageEventHandler.java
+++ b/src/main/java/com/hpcloud/disruptor/event/MetricMessageEventHandler.java
@@ -124,7 +124,7 @@ public class MetricMessageEventHandler implements EventHandler<MetricMessageEven
         }
         if (sequence % batchSize == (batchSize - 1)) {
             TimerContext context = commitTimer.time();
-            verticaMetricRepository.commitBatch();
+            verticaMetricRepository.flush();
             context.stop();
             commitMeter.mark();
         }
diff --git a/src/main/java/com/hpcloud/repository/VerticaMetricRepository.java b/src/main/java/com/hpcloud/repository/VerticaMetricRepository.java
index 6a7809f7..b050e588 100644
--- a/src/main/java/com/hpcloud/repository/VerticaMetricRepository.java
+++ b/src/main/java/com/hpcloud/repository/VerticaMetricRepository.java
@@ -104,7 +104,7 @@ public class VerticaMetricRepository extends VerticaRepository {
 
     }
 
-    public void commitBatch() {
+    private void commitBatch() {
         long startTime = System.currentTimeMillis();
         metricsBatch.execute();
         stagedDefinitionsBatch.execute();