Merge pull request #10 from launchdarkly/jko/flush

Add a flush function, and make close call flush.

Author: jkodumal

build.gradle

@@ -11,7 +11,7 @@ repositories {
 
 allprojects {
     group = 'com.launchdarkly'
-    version = "0.4.0"
+    version = "0.4.1"
     sourceCompatibility = 1.6
     targetCompatibility = 1.6
 }

src/main/java/com/launchdarkly/client/EventProcessor.java

@@ -21,11 +21,13 @@ class EventProcessor implements Closeable {
   private final ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor(new DaemonThreadFactory());
   private final BlockingQueue<Event> queue;
   private final String apiKey;
+  private final Consumer consumer;
 
   EventProcessor(String apiKey, LDConfig config) {
     this.apiKey = apiKey;
     this.queue = new ArrayBlockingQueue<Event>(config.capacity);
-    this.scheduler.scheduleAtFixedRate(new Consumer(config), 0, config.flushInterval, TimeUnit.SECONDS);
+    this.consumer = new Consumer(config);
+    this.scheduler.scheduleAtFixedRate(consumer, 0, config.flushInterval, TimeUnit.SECONDS);
   }
 
   boolean sendEvent(Event e) {
@@ -35,6 +37,11 @@ boolean sendEvent(Event e) {
   @Override
   public void close() throws IOException {
     scheduler.shutdown();
+    this.flush();
+  }
+
+  public void flush() {
+    this.consumer.flush();
   }
 
   static class DaemonThreadFactory implements ThreadFactory {
@@ -59,6 +66,10 @@ class Consumer implements Runnable {
 
     @Override
     public void run() {
+      flush();
+    }
+
+    public void flush() {
       List<Event> events = new ArrayList<Event>(queue.size());
       queue.drainTo(events);
 

src/main/java/com/launchdarkly/client/LDClient.java

@@ -20,7 +20,6 @@
 import java.io.Closeable;
 import java.io.IOException;
 import java.lang.reflect.Type;
-import java.net.URI;
 import java.net.URL;
 import java.util.jar.Attributes;
 import java.util.jar.Manifest;
@@ -241,6 +240,9 @@ public void close() throws IOException {
     this.eventProcessor.close();
   }
 
+  public void flush() {
+    this.eventProcessor.flush();
+  }
 
   /**
    * Puts the LaunchDarkly client in offline mode.