diff options
author | Pawel <pawel.kasperkiewicz@nokia.com> | 2021-06-18 15:26:31 +0200 |
---|---|---|
committer | Pawel <pawel.kasperkiewicz@nokia.com> | 2021-06-18 15:26:31 +0200 |
commit | 1a2435d72a46d8daec2a0259275fee4842da5a9a (patch) | |
tree | d9cc01dfa41912b9adbb563952c56b90d347ad89 /tests/dcaegen2/testcases/resources/robot_library/dmaap_simulator/DMaaPHandler.py | |
parent | b950ff8ea39c666ba3e593d051cfd826be6fd080 (diff) |
CSIT tests update for Synchronous VES collector
-When evens belonging to different domains are reported in eventBatch
-When different stndDefinedNamespace is used if domain==stndDefined
-Error codes resulting from DMaaP-MR errors, mapped to HTTP/503
Issue-ID: DCAEGEN2-1483
Signed-off-by: Pawel <pawel.kasperkiewicz@nokia.com>
Change-Id: I4c993e4c7bfd22981030c69e126e90bbf7e48d4a
Diffstat (limited to 'tests/dcaegen2/testcases/resources/robot_library/dmaap_simulator/DMaaPHandler.py')
-rw-r--r-- | tests/dcaegen2/testcases/resources/robot_library/dmaap_simulator/DMaaPHandler.py | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/tests/dcaegen2/testcases/resources/robot_library/dmaap_simulator/DMaaPHandler.py b/tests/dcaegen2/testcases/resources/robot_library/dmaap_simulator/DMaaPHandler.py index f1c46e19..cc73c36a 100644 --- a/tests/dcaegen2/testcases/resources/robot_library/dmaap_simulator/DMaaPHandler.py +++ b/tests/dcaegen2/testcases/resources/robot_library/dmaap_simulator/DMaaPHandler.py @@ -19,9 +19,11 @@ try: except ImportError: from StringIO import StringIO - class DMaaPHandler(BaseHTTPServer.BaseHTTPRequestHandler): + DEFAULT_SUCCES_RESPONSE_CODE=200 + succes_response_code=DEFAULT_SUCCES_RESPONSE_CODE + def __init__(self, dmaap_simulator, *args): self.dmaap_simulator = dmaap_simulator BaseHTTPServer.BaseHTTPRequestHandler.__init__(self, *args) @@ -66,7 +68,7 @@ class DMaaPHandler(BaseHTTPServer.BaseHTTPRequestHandler): if 'clientThrottlingState' in self.requestline: self.send_response(204) else: - self.send_response(200) + self.send_response(self.succes_response_code) self.send_header('Content-Type', 'application/json') self.end_headers() self.wfile.write("{'count': 1, 'serverTimeMs': 3}") |