aboutsummaryrefslogtreecommitdiffstats
path: root/catalog/pub/Dmaap-lib/nfvo-dmaap-python-lib/nfvo-dmaap-nfvo-v4.0-devel-ns/client/dmaap/consumer.py
diff options
context:
space:
mode:
authormaopeng zhang <zhang.maopeng1@zte.com.cn>2020-01-13 08:56:42 +0000
committerGerrit Code Review <gerrit@onap.org>2020-01-13 08:56:42 +0000
commitaf131a282da8fea1f50c8e8f721cbcd628bb6ea7 (patch)
treecba7c655f726f2bbb4fc84e5fad4af359d9106d8 /catalog/pub/Dmaap-lib/nfvo-dmaap-python-lib/nfvo-dmaap-nfvo-v4.0-devel-ns/client/dmaap/consumer.py
parent315769580a21ee8b59aba8b1b87a7efb8c4883e9 (diff)
parent207d8b4d6e24ff4f4a22a5e91eef32f3667df28a (diff)
Merge "Add ut for dmaap in catalog"
Diffstat (limited to 'catalog/pub/Dmaap-lib/nfvo-dmaap-python-lib/nfvo-dmaap-nfvo-v4.0-devel-ns/client/dmaap/consumer.py')
-rw-r--r--catalog/pub/Dmaap-lib/nfvo-dmaap-python-lib/nfvo-dmaap-nfvo-v4.0-devel-ns/client/dmaap/consumer.py6
1 files changed, 5 insertions, 1 deletions
diff --git a/catalog/pub/Dmaap-lib/nfvo-dmaap-python-lib/nfvo-dmaap-nfvo-v4.0-devel-ns/client/dmaap/consumer.py b/catalog/pub/Dmaap-lib/nfvo-dmaap-python-lib/nfvo-dmaap-nfvo-v4.0-devel-ns/client/dmaap/consumer.py
index e5677d8c..dcc7f956 100644
--- a/catalog/pub/Dmaap-lib/nfvo-dmaap-python-lib/nfvo-dmaap-nfvo-v4.0-devel-ns/client/dmaap/consumer.py
+++ b/catalog/pub/Dmaap-lib/nfvo-dmaap-python-lib/nfvo-dmaap-nfvo-v4.0-devel-ns/client/dmaap/consumer.py
@@ -24,7 +24,8 @@ logger = logging.getLogger(__name__)
class ConsumerClient:
- def __init__(self, host, topic, consumer_group, consumer_id, timeout_ms=-1, limit=-1, filter=''):
+ def __init__(self, host, topic, consumer_group, consumer_id, timeout_ms=-1, limit=-1, filter='',
+ api_key='', api_secret=''):
self.host = host
self.topic = topic
self.group = consumer_group
@@ -32,8 +33,11 @@ class ConsumerClient:
self.timeout_ms = timeout_ms
self.limit = limit
self.filter = filter
+ self.api_key = api_key
+ self.api_secret = api_secret
def set_api_credentials(self, api_key, api_secret):
+
self.api_key = api_key
self.api_secret = api_secret