diff --git a/def.go b/def.go
index 6658661..ef13bd8 100644
--- a/def.go
+++ b/def.go
@@ -115,6 +115,7 @@ const (
 	SQLCWMsgWorkers       = 6
 	SQLIdentifyMsgWorkers = 6
 	SQLJobWorkers         = 3
+	SQLJobSliceSize       = 25
 )
 
 var (
diff --git a/sql.go b/sql.go
index d4655d3..611265e 100644
--- a/sql.go
+++ b/sql.go
@@ -1385,10 +1385,10 @@ func loadCurrentJobs() ([]Job, error) {
 	}
 	defer tx.Rollback()
 
-	stmt, err := tx.Prepare("SELECT o.id, o.obj_sub_type_id, j.payload FROM obj_job j, obj o WHERE j.obj_id = o.id AND j.status = ? AND j.schedule <= ? ORDER BY j.prio ASC LIMIT 10 FOR UPDATE;")
+	stmt, err := tx.Prepare("SELECT o.id, o.obj_sub_type_id, j.payload FROM obj_job j, obj o WHERE j.obj_id = o.id AND j.status = ? AND j.schedule <= ? ORDER BY j.prio ASC LIMIT ? FOR UPDATE;")
 	logOnError(err, "loadCurrentJobs : prepare select statement")
 
-	rows, err := stmt.Query(objJobStatusNew, time.Now())
+	rows, err := stmt.Query(objJobStatusNew, time.Now(), SQLJobSliceSize)
 	logOnError(err, "loadCurrentJobs : query select statement")
 
 	for rows.Next() {