         
         /* Reconciler protocol implementation */
         public func reconciler(reconciler: ModelReconciler, didCreateEvent event: Sync.Event) {
-            self.publish(event)
+            self.enqueue(event)
         }
         
         /* Transportable protocol implementation */

            return dictionary
        }
    }
}

        /// This collection is drained as events get published.
        public private(set) var queuedEvents: Array<Event> = []
        
        /// Serial dispatch queue guarding the `self.queuedEvents` collection.
        private var publicationQueue = dispatch_queue_create("sync.client.publicationSerialQueue", DISPATCH_QUEUE_SERIAL)
        
        init(transport: Transport, modelReconciler: ModelReconciler) {
            self.transport = transport
            self.modelReconciler = modelReconciler;
