Added more cases to JSONKey

John-Connolly · Sep 6, 2017 · 38c8ca0 · 38c8ca0
1 parent c36aa4e
commit 38c8ca0
Show file tree

Hide file tree

Showing 3 changed files with 16 additions and 16 deletions.
diff --git a/Sources/Decoder.swift b/Sources/Decoder.swift
@@ -24,7 +24,7 @@ struct Decoder {
     func decode(data: Foundation.Data) throws -> DecoderResult {
         let json = try data.jsonDictionary(key: String.self, value: Any.self)
 
-        let taskType = TaskType(json["taskType"] as? String ?? "")
+        let taskType = TaskType(json[.taskType] as? String ?? "")
 
         switch taskType {
         case .chain:
@@ -47,7 +47,7 @@ struct Decoder {
 
 
     func decode(chain json: [String : Any]) throws -> Chain {
-        guard let chain = json["chain"] as? [[String : Any]] else {
+        guard let chain = json[.chain] as? [[String : Any]] else {
             throw SwiftQError.taskNotFound
         }
 

diff --git a/Sources/JSON.swift b/Sources/JSON.swift
@@ -75,3 +75,16 @@ public struct JSON {
     }
 
 }
+
+enum JSONKey: String {
+    case taskName
+    case identification
+    case args
+    case error
+    case errorAt
+    case consumer
+    case chain
+    case createdAt
+    case uuid
+    case taskType
+}
diff --git a/Sources/SwiftQProducer.swift b/Sources/SwiftQProducer.swift
@@ -15,7 +15,7 @@ public final class SwiftQProducer {
     private let scheduledQueue: ScheduledQueue
 
     public init(redisConfig: RedisConfig) throws {
-        self.reliableQueue = try ReliableQueue(config: redisConfig)
+        self.reliableQueue = try ReliableQueue(config: redisConfig, concurrency: 4)
         self.scheduledQueue = try ScheduledQueue(config: redisConfig)
 
         if redisConfig.password == nil {
@@ -54,16 +54,3 @@ public final class SwiftQProducer {
     }
 
 }
-
-
-enum JSONKey: String {
-    case taskName
-    case identification
-    case args
-    case error
-    case errorAt
-    case consumer
-    case chain
-    case createdAt
-    case uuid
-}