diff options
| author |   PrakashH <pbhandar@techmahindra.com> | 2019-01-30 06:20:06 +0000 |
|---|---|---|
| committer | PrakashH <pbhandar@techmahindra.com> | 2019-01-30 06:23:50 +0000 |
| commit | 5e4ea155f6766e19d245173a10d15ebe3618c9d1 (patch) | |
| tree | 0e22f08a53b1a62bb922d4bd85d9fa96f314fd63 /miss_htbt_service | |
| parent | a86243058c2daa560aebaecdb096ff63788a6f44 (diff) | |
Heartbeat Microservice Support
Heartbeat service monitors missing HB notifications
Issue-ID: DCAEGEN2-267
Change-Id: I08046dc804e2e927ef03865d22940016acd00656
Signed-off-by: PrakashH <pbhandar@techmahindra.com>
Diffstat (limited to 'miss_htbt_service')
| -rw-r--r-- | miss_htbt_service/htbtworker.py | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/miss_htbt_service/htbtworker.py b/miss_htbt_service/htbtworker.py index cb7465c..6dbd6cd 100644 --- a/miss_htbt_service/htbtworker.py +++ b/miss_htbt_service/htbtworker.py @@ -97,13 +97,17 @@ def process_msg(jsfile,user_name, password, ip_address, port_num, db_name): continue jlist = inputString.split('\n'); # Process the DMaaP input message retreived + error = False for line in jlist: try: jobj = json.loads(line) except ValueError: msg='HBT:Decoding JSON has failed' _logger.error(msg) - continue + error = True + break + if (error == True): + continue if len(jobj) == 0: continue for item in jobj: |