 
     originalAdded = publish.added
     publish.added = (collectionName, id, fields) ->
+      return originalAdded.call @, collectionName, id, fields unless disabled
+
       stringId = @_idFilter.idStringify id
-
-      return originalAdded.call @, collectionName, id, fields unless disabled
 
       FiberUtils.synchronize guardObject, "#{collectionName}$#{stringId}", =>
         collectionView = @_session.getCollectionView collectionName


    originalRemoved = publish.removed
    publish.removed = (collectionName, id) ->
      stringId = @_idFilter.idStringify id

      return originalRemoved.call @, collectionName, id unless disabled

      FiberUtils.synchronize guardObject, "#{collectionName}$#{stringId}", =>
        collectionView = @_session.getCollectionView collectionName


    originalChanged = publish.changed
    publish.changed = (collectionName, id, fields) ->
      return originalChanged.call @, collectionName, id, fields unless disabled

      stringId = @_idFilter.idStringify id

      FiberUtils.synchronize guardObject, "#{collectionName}$#{stringId}", =>
        collectionView = @_session.getCollectionView collectionName

        if collectionView.documents instanceof Map
