Class: OpenC3::QueueTopic

Inherits:
Topic show all
Defined in:
lib/openc3/topics/queue_topic.rb

Constant Summary collapse

PRIMARY_KEY = 
"openc3_queue"

Class Method Summary collapse

Methods inherited from Topic

all_same_db_shard?, clear_topics, del, get_cnt, get_last_offset, get_newest_message, get_oldest_message, group_topics_by_db_shard, method_missing, read_topics, trim_topic, update_topic_offsets, write_ack, write_topic

Class Method Details

.write_notification(notification, scope:) ⇒ Object 



20
21
22
 
# File 'lib/openc3/topics/queue_topic.rb', line 20

def self.write_notification(notification, scope:)
  Topic.write_topic("#{scope}__#{PRIMARY_KEY}", notification, '*', 1000)
end