       aggregate = @_aggregateInstances[commandId][aggregateId]
       if not aggregate
         err = "Tried to save unknown aggregate #{@_aggregateName}"
-        eventric.log.error err
+        @_eventric.log.error err
         err = new Error err
         callback? err, null
         reject err

        else
          if not @_context.isWaitingModeEnabled()
            for domainEvent in domainEvents
              eventric.log.debug "Publishing DomainEvent", domainEvent
              @_context.getEventBus().publishDomainEvent domainEvent
            resolve aggregate.id
            callback null, aggregate.id
          else
            eventric.eachSeries domainEvents, (domainEvent, next) =>
              eventric.log.debug "Publishing DomainEvent in waiting mode", domainEvent
              @_context.getEventBus().publishDomainEventAndWait domainEvent
              .then ->
                next()

      domainEvents   = aggregate.getDomainEvents()
      if domainEvents.length < 1
        err = "Tried to save 0 DomainEvents from Aggregate #{@_aggregateName}"
        @_eventric.log.debug err, @_command
        err = new Error err
        callback? err, null
        reject err
        return

      @_eventric.log.debug "Going to Save and Publish #{domainEvents.length} DomainEvents from Aggregate #{@_aggregateName}"

      # TODO: this should be an transaction to guarantee consistency
      @_eventric.eachSeries domainEvents, (domainEvent, next) =>
        domainEvent.command = @_command
        @_store.saveDomainEvent domainEvent, =>
          @_eventric.log.debug "Saved DomainEvent", domainEvent
          next null
      , (err) =>
        if err
