- get the aggregate_id for the events that need to be reprocessed (the last successful event).
- You can do this via the Platform CLI or the
rails c
of the app in question (the former is the most advisable). - The new Shari
reprocess
helper method can simply take the aggregate as the arg like so:reprocess(aggregate_id)
|
- Get the event id/s for the event/s that weren't handled
- Connect to console for the app in question
3. then
sudo su deploy
,cd/app_name/current
etc. - Retrieve the event/s
e = Shari::Repositories::EventRecord.where(id: ["158674a1-9331-5004-a548-3eddcf0eb718", "81a6768a-742f-58a3-9d70-ff68e97124fd", "3828c7d9-8954-53f7-80fe-b71888eebc87"])
- reprocess the event/s that initially failed to be handled
e.each { |event| Shari::Services::EventProcessor.process(event.attributes)