add prefix for sqs message group id

This commit is contained in:
r888888888
2017-06-13 16:36:39 -07:00
parent efe5e0e95e
commit 4a07848b6d
2 changed files with 2 additions and 2 deletions

View File

@@ -59,7 +59,7 @@ class PoolArchive < ActiveRecord::Base
category: pool.category
}
msg = "add pool version\n#{json.to_json}"
sqs_service.send_message(msg, message_group_id: "#{pool.id}")
sqs_service.send_message(msg, message_group_id: "pool:#{pool.id}")
end
def build_diff(other = nil)

View File

@@ -74,7 +74,7 @@ class PostArchive < ActiveRecord::Base
"tags" => post.tag_string
}
msg = "add post version\n#{json.to_json}"
sqs_service.send_message(msg, message_group_id: "#{post.id}")
sqs_service.send_message(msg, message_group_id: "post:#{post.id}")
end
end
end