Merge pull request #4 from vapor-community/push-update

Implemented push to support delayed jobs.

Sources/QueuesMongoDriver/Queues.swift

@@ -97,8 +97,15 @@ class MongoQueue: Queue {
         }
     }
 
+    // Mark jobs that can't be finished as ready.
     func push(_ id: JobIdentifier) -> EventLoopFuture<Void> {
-        context.eventLoop.future()
+        mongodb["vapor_queue"]
+        .findAndModify(where: ["jobid": id.string,
+                               "queue": "\(context.queueName.string)",
+                               "status": "processing"],
+                       update: ["$set": ["status": MongoJobStatus.ready.rawValue]])
+        .execute()
+        .transform(to: ())
     }
 }