Fixed SyncThreadedJobQueue

Author: JanHolger

src/main/java/org/javawebstack/framework/WebApplication.java

@@ -135,7 +135,7 @@ public void enableDatabaseJobs(ORMConfig config) throws ORMConfigurationExceptio
     }
 
     public void addSyncJobQueue(String name, int capacity, boolean defaultQueue){
-        addQueue(name, new SyncThreadedJobQueue(capacity), defaultQueue);
+        addQueue(name, new SyncThreadedJobQueue(capacity).start(), defaultQueue);
     }
 
     public void addImmediateJobQueue(String name, boolean defaultQueue){

src/main/java/org/javawebstack/framework/job/SyncThreadedJobQueue.java

@@ -3,7 +3,7 @@
 import java.util.Queue;
 import java.util.concurrent.ArrayBlockingQueue;
 
-public class SyncThreadedJobQueue implements JobQueue {
+public class SyncThreadedJobQueue implements JobQueue, Runnable {
     private final Queue<Job> queue;
     public SyncThreadedJobQueue(int limit){
         queue = new ArrayBlockingQueue<>(limit);
@@ -17,7 +17,8 @@ public void run() {
             job.run();
         }
     }
-    public void start(){
+    public SyncThreadedJobQueue start(){
         new Thread(this).start();
+        return this;
     }
 }