DEV: Fix another MessageBus::InvalidMessageTarget error.

Follow-up to c2f2b57a9b.
This commit is contained in:
Guo Xiang Tan
2020-09-15 14:25:10 +08:00
parent f7438fc64b
commit 49f53bdc50

View File

@@ -438,6 +438,7 @@ SQL
}
channels.each do |channel, ids|
if ids.present?
MessageBus.publish(
channel,
message.as_json,
@@ -445,6 +446,7 @@ SQL
)
end
end
end
def self.publish_read_indicator_on_write(topic_id, last_read_post_number, user_id)
topic = Topic.includes(:allowed_groups).select(:highest_post_number, :archetype, :id).find_by(id: topic_id)