Attempt at implementing shutdown() to avoid hanging when application …

…exits

Sources/QueuesFluentDriver/FluentQueuesDriver.swift

@@ -12,11 +12,13 @@ public struct FluentQueuesDriver {
     let databaseId: DatabaseID?
     let dbType: QueuesFluentDbType
     let useSoftDeletes: Bool
+    let eventLoopGroup: EventLoopGroup
 
-    init(on databaseId: DatabaseID? = nil, useSoftDeletes: Bool) {
+    init(on databaseId: DatabaseID? = nil, useSoftDeletes: Bool, on: EventLoopGroup) {
         self.databaseId = databaseId
         self.useSoftDeletes = useSoftDeletes
         self.dbType = .postgresql
+        self.eventLoopGroup = on
     }
 }
 
@@ -35,5 +37,8 @@ extension FluentQueuesDriver: QueuesDriver {
         )
     }
 
-    public func shutdown() {}
+    public func shutdown() {
+        // What are we supposed to do here?
+        try? self.eventLoopGroup.syncShutdownGracefully()
+    }
 }

Sources/QueuesFluentDriver/Queues.Provider+fluent.swift

@@ -9,7 +9,7 @@ extension Application.Queues.Provider {
     public static func fluent(_ databaseId: DatabaseID? = nil, useSoftDeletes: Bool = true) -> Self {
         .init {
             $0.queues.use(custom:
-                FluentQueuesDriver(on: databaseId, useSoftDeletes: useSoftDeletes)
+                FluentQueuesDriver(on: databaseId, useSoftDeletes: useSoftDeletes, on: $0.eventLoopGroup)
             )
         }
     }