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

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

        @_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
