lib/openc3/topics/command_topic.rb in openc3-5.14.2 vs lib/openc3/topics/command_topic.rb in openc3-5.15.0

- old
+ new

@@ -19,10 +19,11 @@ # # This file may also be used under the terms of a commercial license # if purchased from OpenC3, Inc. require 'openc3/topics/topic' +require 'openc3/utilities/store_queued' require 'openc3/utilities/open_telemetry' module OpenC3 class CommandTopic < Topic COMMAND_ACK_TIMEOUT_S = 5 @@ -34,10 +35,10 @@ target_name: packet.target_name, packet_name: packet.packet_name, received_count: packet.received_count, stored: packet.stored.to_s, buffer: packet.buffer(false) } - Topic.write_topic(topic, msg_hash) + EphemeralStoreQueued.write_topic(topic, msg_hash) end # @param command [Hash] Command hash structure read to be written to a topic def self.send_command(command, timeout: COMMAND_ACK_TIMEOUT_S, scope:) timeout = COMMAND_ACK_TIMEOUT_S unless timeout