diff options
Diffstat (limited to 'miss_htbt_service/htbtworker.py')
| -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: |