         self.collectionsLocalStorage = [:]
         self.modifiedCollections = [:]
 
-        databaseWriteQueue.setSpecific(key: connectionQueueKey, value: id)
+        connectionQueue.setSpecific(key: connectionQueueKey, value: id)
 
         self.sqlite = try SQLiteAdapter(sqliteDatabaseUrl: database.url)
         try self.createExtensionConnections()


    // MARK: Private properties

    private let databaseWriteQueue: DispatchQueue
    private var connectionModificationLock: OSSpinLock = OS_SPINLOCK_INIT


public final class Connection<Collections: CollectionsContainer> {
    // MARK: Public properties

