This is an automated email from the ASF dual-hosted git repository.
rabbah pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-openwhisk.git
The following commit(s) were added to refs/heads/master by this push:
new 17b9f43 Delete unnecessary code comments (#4128)
17b9f43 is described below
commit 17b9f438bb961195ba1f39d0eb6732169b216ad8
Author: 김건희 <[email protected]>
AuthorDate: Sat Nov 24 06:31:25 2018 +0900
Delete unnecessary code comments (#4128)
---
.../loadBalancer/ShardingContainerPoolBalancer.scala | 16 ----------------
1 file changed, 16 deletions(-)
diff --git
a/core/controller/src/main/scala/org/apache/openwhisk/core/loadBalancer/ShardingContainerPoolBalancer.scala
b/core/controller/src/main/scala/org/apache/openwhisk/core/loadBalancer/ShardingContainerPoolBalancer.scala
index 5348d37..35a4547 100644
---
a/core/controller/src/main/scala/org/apache/openwhisk/core/loadBalancer/ShardingContainerPoolBalancer.scala
+++
b/core/controller/src/main/scala/org/apache/openwhisk/core/loadBalancer/ShardingContainerPoolBalancer.scala
@@ -469,22 +469,6 @@ object ShardingContainerPoolBalancer extends
LoadBalancerProvider {
logging: Logging,
materializer: ActorMaterializer): LoadBalancer = {
-// private val activeAckTopic = s"completed${controllerInstance.asString}"
-// private val maxActiveAcksPerPoll = 128
-// private val activeAckPollDuration = 1.second
-// private val activeAckConsumer =
-// messagingProvider.getConsumer(config, activeAckTopic, activeAckTopic,
maxPeek = maxActiveAcksPerPoll)
-//
-// private val activationFeed = actorSystem.actorOf(Props {
-// new MessageFeed(
-// "activeack",
-// logging,
-// activeAckConsumer,
-// maxActiveAcksPerPoll,
-// activeAckPollDuration,
-// processAcknowledgement)
-// })
-
val activeAckTopic = s"completed${instance.asString}"
val maxActiveAcksPerPoll = 128
val activeAckPollDuration = 1.second