summaryrefslogtreecommitdiffstats
path: root/dmaap/dmaapcontrollerif/dmaap_requests.py
diff options
context:
space:
mode:
authorJoeOLeary <joseph.o.leary@est.tech>2019-06-25 13:26:56 +0000
committerJoeOLeary <joseph.o.leary@est.tech>2019-06-25 13:26:56 +0000
commit6b5636fe2ddaab95d180876127701e71639faf78 (patch)
tree65d2bb167b4726ff31277fbfbae1b246e017ad4a /dmaap/dmaapcontrollerif/dmaap_requests.py
parentd206b39f669ff86e469918ef1db5d3e75f4d18d4 (diff)
Update DMaaP plugin - DataRouter subscriber creation
- Add privileged subscriber flag. - Add decompression flag. Change-Id: Id3c2e7fb88d858f4a1ebe4e1ab86598c0f3f30a0 Issue-ID: DCAEGEN2-1581 Signed-off-by: JoeOLeary <joseph.o.leary@est.tech>
Diffstat (limited to 'dmaap/dmaapcontrollerif/dmaap_requests.py')
-rw-r--r--dmaap/dmaapcontrollerif/dmaap_requests.py6
1 files changed, 4 insertions, 2 deletions
diff --git a/dmaap/dmaapcontrollerif/dmaap_requests.py b/dmaap/dmaapcontrollerif/dmaap_requests.py
index 5506865..813a1d8 100644
--- a/dmaap/dmaapcontrollerif/dmaap_requests.py
+++ b/dmaap/dmaapcontrollerif/dmaap_requests.py
@@ -165,7 +165,7 @@ class DMaaPControllerHandle(object):
# Data Router SUbscrihers
- def add_subscriber(self, feed_id, location, delivery_url, username, password, status=None):
+ def add_subscriber(self, feed_id, location, delivery_url, username, password, decompress, privileged, status=None):
'''
Add a publisher to feed feed_id at location location with user, pass, and status
'''
@@ -174,7 +174,9 @@ class DMaaPControllerHandle(object):
'dcaeLocationName' : location,
'deliveryURL' : delivery_url,
'username' : username,
- 'userpwd' : password
+ 'userpwd' : password,
+ 'decompress': decompress,
+ 'privilegedSubscriber': privileged
}
if status: