diff options
author | JoeOLeary <joseph.o.leary@est.tech> | 2019-06-25 13:26:56 +0000 |
---|---|---|
committer | JoeOLeary <joseph.o.leary@est.tech> | 2019-06-25 13:26:56 +0000 |
commit | 6b5636fe2ddaab95d180876127701e71639faf78 (patch) | |
tree | 65d2bb167b4726ff31277fbfbae1b246e017ad4a /dmaap/dmaapcontrollerif/dmaap_requests.py | |
parent | d206b39f669ff86e469918ef1db5d3e75f4d18d4 (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.py | 6 |
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: |