         else
           if not @_context.isWaitingModeEnabled()
             for domainEvent in domainEvents
-              eventric.log.debug "Publishing DomainEvent", domainEvent
+              @_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
+            @_eventric.eachSeries domainEvents, (domainEvent, next) =>
+              @_eventric.log.debug "Publishing DomainEvent in waiting mode", domainEvent
               @_context.getEventBus().publishDomainEventAndWait domainEvent
               .then ->
                 next()


        if not domainEvents.length
          err = "No domainEvents for #{@_aggregateName} Aggregate with #{aggregateId} available"
          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
