Merge pull request #18 from TaskarCenterAtUW/develop

Develop to Master

Author: susrisha

CHANGELOG.md

@@ -1,5 +1,8 @@
 # Change log
 
+### 0.0.16
+- Removed extra logs
+
 ### 0.0.15
 This fixes the inconsistent listening behavior for the subscription of a topic from core.
 - Due to the usage of `for message in receiver` logic in the topic, it is unknown when the loop will end and the core will stop listening to the topic.

freeze_version.py

@@ -11,7 +11,7 @@
 
 build_date = date.today().strftime('%Y-%m-%d')
 
-version = '0.0.15'
+version = '0.0.16'
 
 with open(version_file_path, 'w+') as version_file:
     version_file.write("version = '{}'\n".format(version))

src/python_ms_core/core/topic/topic.py

@@ -29,9 +29,7 @@ def messages(self, provider, topic, subscription):
                     except Exception as e:
                         print(f'Error: {e}, Invalid message received: {message}')
                     finally:
-                        print(f'Completing message')
                         topic_receiver.complete_message(message)
-                logger.info(f'Completed gathering messages')
             logger.info('Completed topic receiver')
 
     # Sends data to the callback function
@@ -49,7 +47,6 @@ def start_listening(self, provider, topic, subscription):
                     for message in topic_receiver:
                         try:
                             self.process_message(message=str(message)) # sync call. [By default 1minute ] -> lock renewal for 300 seconds
-                            topic_receiver.complete_message(message)
                         except Exception as e:
                             print(f'Error : {e}, Invalid message received : {message}')
                         finally: