 
         if not domainEvents.length
           err = "No domainEvents for #{@_aggregateName} Aggregate with #{aggregateId} available"
-          eventric.log.error err
+          @_eventric.log.error err
           callback err, null
           reject err
           return

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

      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
