From 872997b58a9b2aeb54d5128a91d95f72d366ae74 Mon Sep 17 00:00:00 2001 From: Shawn Snyder Date: Wed, 18 Dec 2024 17:27:22 -0600 Subject: [PATCH] WIP on master --- example_app.py | 3 +++ intriniorealtime/client.py | 9 +++++---- 2 files changed, 8 insertions(+), 4 deletions(-) diff --git a/example_app.py b/example_app.py index b59fb36..b07d4b3 100644 --- a/example_app.py +++ b/example_app.py @@ -53,6 +53,8 @@ def run(self): # ,'write_to_csv': False # needed for ReplayClient # ,'csv_file_path': 'data.csv' # needed for ReplayClient # ,'bypass_parsing': True # if you want to handle parsing yourself, set this to True. Otherwise, leave it alone. + # ,'debug': True + # ,'max_queue_size': 250000 } @@ -79,6 +81,7 @@ def on_kill_process(sig, frame): summarize_thread.start() time.sleep(120) + # sigint, or ctrl+c, during the thread wait will also perform the same below code. print("Stopping") stop_event.set() diff --git a/intriniorealtime/client.py b/intriniorealtime/client.py index 697023c..77663b8 100644 --- a/intriniorealtime/client.py +++ b/intriniorealtime/client.py @@ -473,7 +473,8 @@ def run(self): while True: message = self.client.quotes.get() backlog_len = self.client.quotes.qsize() - items_in_message = message[0] - start_index = 1 - for i in range(0, items_in_message): - start_index = self.parse_message(message, start_index, backlog_len) \ No newline at end of file + if message is not None and len(message) > 0 and len(message) >= message[0] * 24: #sanity check on length. Should be at least as long as the smallest message times the number of messages it says it has. + items_in_message = message[0] + start_index = 1 + for i in range(0, items_in_message): + start_index = self.parse_message(message, start_index, backlog_len) \ No newline at end of file