openwhisk-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jeremiaswer...@apache.org
Subject [incubator-openwhisk] branch master updated: Give every invoker-topic it's own consumergroup (#3067)
Date Wed, 06 Dec 2017 19:12:53 GMT
This is an automated email from the ASF dual-hosted git repository.

jeremiaswerner 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 6bf70a7  Give every invoker-topic it's own consumergroup (#3067)
6bf70a7 is described below

commit 6bf70a7eb7ce6bc0cb79bf61090812f42e17fc61
Author: Christian Bickel <github@cbickel.de>
AuthorDate: Wed Dec 6 20:12:49 2017 +0100

    Give every invoker-topic it's own consumergroup (#3067)
---
 core/invoker/src/main/scala/whisk/core/invoker/InvokerReactive.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/core/invoker/src/main/scala/whisk/core/invoker/InvokerReactive.scala b/core/invoker/src/main/scala/whisk/core/invoker/InvokerReactive.scala
index 2053e3f..6a4adca 100644
--- a/core/invoker/src/main/scala/whisk/core/invoker/InvokerReactive.scala
+++ b/core/invoker/src/main/scala/whisk/core/invoker/InvokerReactive.scala
@@ -98,7 +98,7 @@ class InvokerReactive(config: WhiskConfig, instance: InstanceId, producer:
Messa
   val msgProvider = SpiLoader.get[MessagingProvider]
   val consumer = msgProvider.getConsumer(
     config,
-    "invokers",
+    topic,
     topic,
     maximumContainers,
     maxPollInterval = TimeLimit.MAX_DURATION + 1.minute)

-- 
To stop receiving notification emails like this one, please contact
['"commits@openwhisk.apache.org" <commits@openwhisk.apache.org>'].

Mime
View raw message