Client runs indefinitely until shut down, added random wait times between sending messages

Exchange/exchange.py

@@ -25,7 +25,7 @@ def generateOrderResponse(incomingMsg):
     msg.append_pair(34, msg_seq_num, header=True)  # MsgSeqNum(34)
     msg.append_pair(35, '8')  # 35: Set  message type
     msg.append_tz_timestamp(52, precision=6, header=True)  # 52: time
-    msg.append_pair(11, incomingMsg.get(11).decode('UTF-8'))
+    msg.append_pair(11, incomingMsg.get(11).decode('UTF-8')) # ClOrdID
     encoded_msg = msg.encode()
     return encoded_msg
 
@@ -36,7 +36,7 @@ def generateMarketDataResponse(incomingMsg):
     msg.append_pair(34, msg_seq_num, header=True)  # MsgSeqNum(34)
     msg.append_pair(35, 'W')  # 35: Set  message type
     msg.append_tz_timestamp(52, precision=6, header=True)  # 52: time
-    msg.append_pair(262, incomingMsg.get(262).decode('UTF-8'))
+    msg.append_pair(262, incomingMsg.get(262).decode('UTF-8')) # MDReqID
     encoded_msg = msg.encode()
     return encoded_msg
 

Trader/trader_msg_generator.py

@@ -117,13 +117,17 @@ if __name__ == '__main__':
     s = socket.socket()
     port = 3125
     s.connect(('localhost', port))
-    threading.Thread(target=recv).start()
-    num_of_msg = 10
-    for i in range(num_of_msg):
-        if i % 2 == 0:
+
+    t = threading.Thread(target=recv)
+    t.daemon = True
+    t.start()
+
+    while True:
+        choice = random.choice([1, 2])
+        if choice == 1:
             z = generate_random_market_data_request()
         else:
             z = generate_random_new_order(None)
         s.sendall(z)
-        time.sleep(0.5)
-    s.close()
\ No newline at end of file
+        time_wait = random.uniform(0.1, 1)
+        time.sleep(time_wait)
\ No newline at end of file