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