new_data_from_server = io["file_in"].read()
ping_test(len(new_data_from_server) > 0)
read_into_message_queue(new_data_from_server)
new_data_from_server = io["file_in"].read()
ping_test(len(new_data_from_server) > 0)
read_into_message_queue(new_data_from_server)