consumer_retry.rb

class Consumer
  include Consumer::Postgres

  handler SomeHandler
  handler SomeOtherHandler

  def error_raised(error, message_data)
    if error.instance_of?(MessageStore::ExpectedVersion::Error)
      self.(message_data)
    else
      raise error
    end
  end
end