aboutsummaryrefslogtreecommitdiffstats
path: root/miss_htbt_service
diff options
context:
space:
mode:
authorPrakashH <pbhandar@techmahindra.com>2019-01-30 06:20:06 +0000
committerPrakashH <pbhandar@techmahindra.com>2019-01-30 06:23:50 +0000
commit5e4ea155f6766e19d245173a10d15ebe3618c9d1 (patch)
tree0e22f08a53b1a62bb922d4bd85d9fa96f314fd63 /miss_htbt_service
parenta86243058c2daa560aebaecdb096ff63788a6f44 (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.py6
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: