Support for LDD

Author: jkodumal

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

@@ -34,6 +34,7 @@ public final class LDConfig {
   final boolean stream;
   final boolean debugStreaming;
   final FeatureStore featureStore;
+  final boolean useLdd;
 
   protected LDConfig(Builder builder) {
     this.baseURI = builder.baseURI;
@@ -46,6 +47,7 @@ protected LDConfig(Builder builder) {
     this.stream = builder.stream;
     this.debugStreaming = builder.debugStreaming;
     this.featureStore = builder.featureStore;
+    this.useLdd = builder.useLdd;
   }
 
   /**
@@ -72,6 +74,7 @@ public static class Builder{
     private String proxyScheme;
     private boolean stream = true;
     private boolean debugStreaming = false;
+    private boolean useLdd = false;
     private FeatureStore featureStore = new InMemoryFeatureStore();
 
     /**
@@ -110,7 +113,7 @@ public Builder featureStore(FeatureStore store) {
      * retrieved feature with the value in the feature store. There is a performance cost to this, so it is not
      * recommended for production use.
      * @param debugStreaming whether streaming mode should be debugged
-     * @return
+     * @return the builder
      */
     public Builder debugStreaming(boolean debugStreaming) {
       this.debugStreaming = debugStreaming;
@@ -215,7 +218,7 @@ public Builder capacity(int capacity) {
      * a proxy will not be used, and {@link LDClient} will connect to LaunchDarkly directly.
      * </p>
      * @param host
-     * @return
+     * @return the builder
      */
     public Builder proxyHost(String host) {
       this.proxyHost = host;
@@ -231,7 +234,7 @@ public Builder proxyHost(String host) {
      * a proxy will not be used, and {@link LDClient} will connect to LaunchDarkly directly.
      * </p>
      * @param port
-     * @return
+     * @return the builder
      */
     public Builder proxyPort(int port) {
       this.proxyPort = port;
@@ -247,13 +250,24 @@ public Builder proxyPort(int port) {
      * a proxy will not be used, and {@link LDClient} will connect to LaunchDarkly directly.
      * </p>
      * @param scheme
-     * @return
+     * @return the builder
      */
     public Builder proxyScheme(String scheme) {
       this.proxyScheme = scheme;
       return this;
     }
 
+    /**
+     * Set whether this client should subscribe to the streaming API, or whether the LaunchDarkly daemon is in use
+     * instead
+     * @param useLdd
+     * @return the builder
+     */
+    public Builder useLdd(boolean useLdd) {
+      this.useLdd = useLdd;
+      return this;
+    }
+
     HttpHost proxyHost() {
       if (this.proxyHost == null && this.proxyPort == -1 && this.proxyScheme == null) {
         return null;

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

@@ -42,6 +42,11 @@ class StreamProcessor implements Closeable {
   }
 
   void subscribe() {
+    // If the LaunchDarkly daemon is to be used, then do not subscribe to the stream
+    if (config.useLdd) {
+      return;
+    }
+
     MultivaluedMap<String, Object> headers = new StringKeyIgnoreCaseMultivaluedMap<Object>();
     headers.putSingle("Authorization", "api_key " + this.apiKey);
     headers.putSingle("User-Agent", "JavaClient/" + LDClient.CLIENT_VERSION);