From 6b5636fe2ddaab95d180876127701e71639faf78 Mon Sep 17 00:00:00 2001
From: JoeOLeary <joseph.o.leary@est.tech>
Date: Tue, 25 Jun 2019 13:26:56 +0000
Subject: 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>
---
 dmaap/dmaapcontrollerif/dmaap_requests.py | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

(limited to 'dmaap/dmaapcontrollerif/dmaap_requests.py')

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:
-- 
cgit 1.2.3-korg