       async.eachSeries @_projectionClasses, (projection, next) =>
         @clearProjectionStore projection.name
         .then =>
-          @projectionStore projection.name
+          @getProjectionStore projection.name
         .then (projectionStore) =>
           @_initializeProjection projection, projectionStore, =>
             next()

      $domainService: =>
        (@getDomainService arguments[0]).apply @, [arguments[1], arguments[2]]
      $projectionStore: (projectionName, callback) =>
        @projectionStore projectionName, callback

    @_initializeProjections()
    .then =>

        @_eventBus.subscribeToDomainEvent domainEventName, domainEventHandler


  getProjectionStore: (projectionName, callback) =>
    new Promise (resolve, reject) =>

      @_store.getProjectionStore (@_projectionStoreName projectionName), (err, projectionStore) =>
        callback? err, projectionStore
        return reject err if err
        resolve projectionStore
