DEVX-533: Implement LoadBalancer Strategy based on annotation

- switched on MuxBalancer for the standalone

Author: vrann

core/standalone/src/main/resources/standalone.conf

@@ -56,6 +56,12 @@ whisk {
     limits-actions-invokes-concurrent = 30
   }
 
+  loadbalancer {
+    strategy {
+      default = "org.apache.openwhisk.core.loadBalancer.LeanBalancer"
+    }
+  }
+
   controller {
     protocol = http
 

core/standalone/src/main/scala/org/apache/openwhisk/standalone/KafkaLauncher.scala

@@ -28,7 +28,7 @@ import org.apache.openwhisk.common.{Logging, TransactionId}
 import org.apache.openwhisk.core.WhiskConfig
 import org.apache.openwhisk.core.WhiskConfig.kafkaHosts
 import org.apache.openwhisk.core.entity.ControllerInstanceId
-import org.apache.openwhisk.core.loadBalancer.{LeanBalancer, LoadBalancer, LoadBalancerProvider}
+import org.apache.openwhisk.core.loadBalancer.{LoadBalancer, LoadBalancerProvider, MuxBalancer}
 import org.apache.openwhisk.standalone.StandaloneDockerSupport.{checkOrAllocatePort, containerName, createRunCmd}
 
 import scala.concurrent.{ExecutionContext, Future}
@@ -113,12 +113,12 @@ class KafkaLauncher(docker: StandaloneDockerClient,
 }
 
 object KafkaAwareLeanBalancer extends LoadBalancerProvider {
-  override def requiredProperties: Map[String, String] = LeanBalancer.requiredProperties ++ kafkaHosts
+  override def requiredProperties: Map[String, String] = MuxBalancer.requiredProperties ++ kafkaHosts
 
   override def instance(whiskConfig: WhiskConfig, instance: ControllerInstanceId)(
     implicit actorSystem: ActorSystem,
     logging: Logging,
-    materializer: ActorMaterializer): LoadBalancer = LeanBalancer.instance(whiskConfig, instance)
+    materializer: ActorMaterializer): LoadBalancer = MuxBalancer.instance(whiskConfig, instance)
 }
 
 object KafkaLauncher {