Method: OpenC3::TextLogMicroservice#run

Defined in:
lib/openc3/microservices/text_log_microservice.rb

#run ⇒ Object 



43
44
45
46
47
48
49
50
51
52
53
54
 
# File 'lib/openc3/microservices/text_log_microservice.rb', line 43

def run
  tlws = setup_tlws
  while true
    break if @cancel_thread

    Topic.read_topics(@topics) do |topic, msg_id, msg_hash, redis|
      break if @cancel_thread

      log_data(tlws, topic, msg_id, msg_hash, redis)
    end
  end
end