diff options
| author |   PrakashH <pbhandar@techmahindra.com> | 2019-01-30 06:20:06 +0000 |
|---|---|---|
| committer | Prakash H <pbhandar@techmahindra.com> | 2019-01-31 06:41:16 +0000 |
| commit | 8322befecfbd488e239ba3405ac5c3d6c641b38e (patch) | |
| tree | d3aa463daab7f8cac7e92c1bf67e17e32b02aca2 | |
| parent | 20110ffeb5071193e7b437e797636d9d6318dcd4 (diff) | |
Heartbeat Microservice Support
Heartbeat service monitors missing HB notifications
Issue-ID: DCAEGEN2-267
Change-Id: I08046dc804e2e927ef03865d22940016acd00656
Signed-off-by: PrakashH <pbhandar@techmahindra.com>
(cherry picked from commit 5e4ea155f6766e19d245173a10d15ebe3618c9d1)
| -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 5b62943..b39cae7 100644 --- a/miss_htbt_service/htbtworker.py +++ b/miss_htbt_service/htbtworker.py @@ -98,13 +98,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: |