diff options
| author |   Vijay Venkatesh Kumar <vv770d@att.com> | 2019-01-31 18:51:11 +0000 |
|---|---|---|
| committer |   Gerrit Code Review <gerrit@onap.org> | 2019-01-31 18:51:11 +0000 |
| commit | fde3682c0073d6d8c57acd7d95850f166a190868 (patch) | |
| tree | 0e22f08a53b1a62bb922d4bd85d9fa96f314fd63 | |
| parent | d9fe6d3403cb0c3a8b0260c537e0470eb6ef5d60 (diff) | |
| parent | 8322befecfbd488e239ba3405ac5c3d6c641b38e (diff) | |
Merge "Heartbeat Microservice Support" into ves-cl-outputsupport
| -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: |