debug

m-barthelemy · Apr 6, 2020 · d9e723e · d9e723e
1 parent 6141281
commit d9e723e
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/Sources/QueuesFluentDriver/FluentQueue.swift b/Sources/QueuesFluentDriver/FluentQueue.swift
@@ -90,6 +90,7 @@ extension FluentQueue: Queue {
             return self.context.eventLoop.makeFailedFuture(QueuesFluentError.databaseNotFound)
         }
         let db = database as! SQLDatabase
+        print("••••• dialect name: \(db.dialect.name)")
 
         var selectQuery = db
             .select ()

diff --git a/Sources/QueuesFluentDriver/PopQueries/SqlitePopQuery.swift b/Sources/QueuesFluentDriver/PopQueries/SqlitePopQuery.swift
@@ -6,6 +6,8 @@ import Queues
 final class SqlitePop : PopQueryProtocol {
     func pop(db: Database, select: SQLExpression) -> EventLoopFuture<UUID?> {
         let database = db as! SQLDatabase
+        //let beginImmediateTrxn = database.raw("BEGIN IMMEDIATE").
+
         return database.raw(SQLQueryString("BEGIN IMMEDIATE")).run().flatMap { void in
             var id: UUID?
             return database.execute(sql: select) { (row) -> Void in