add message group id for post archives
This commit is contained in:
@@ -59,7 +59,7 @@ class PoolArchive < ActiveRecord::Base
|
|||||||
category: pool.category
|
category: pool.category
|
||||||
}
|
}
|
||||||
msg = "add pool version\n#{json.to_json}"
|
msg = "add pool version\n#{json.to_json}"
|
||||||
sqs_service.send_message(msg)
|
sqs_service.send_message(msg, message_group_id: "#{pool.id}")
|
||||||
end
|
end
|
||||||
|
|
||||||
def build_diff(other = nil)
|
def build_diff(other = nil)
|
||||||
|
|||||||
@@ -74,7 +74,7 @@ class PostArchive < ActiveRecord::Base
|
|||||||
"tags" => post.tag_string
|
"tags" => post.tag_string
|
||||||
}
|
}
|
||||||
msg = "add post version\n#{json.to_json}"
|
msg = "add post version\n#{json.to_json}"
|
||||||
sqs_service.send_message(msg)
|
sqs_service.send_message(msg, message_group_id: "#{post.id}")
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|||||||
Reference in New Issue
Block a user