def load(aggregate_class, aggregate_id)
      events = event_source.get_events_for_aggregate_id(aggregate_id)
      aggregate_class.new(aggregate_id, events)
    end
def load(aggregate_class, aggregate_id)
      events = event_source.get_events_for_aggregate_id(aggregate_id)
      aggregate_class.new(aggregate_id, events)
    end
@param event_source event source to be used for loading the events for the aggregate
 @param event_sink event sink to be used for saving any new events for the aggregate
 Load an aggregate instance

 @param aggregate_class Aggregate type
 @param aggregate_id [Integer] ID of the aggregate instance to be loaded