Disable loading jobs from db from a disabled listener

axieinfinity · Aug 3, 2022 · 2dd817d · 2dd817d
1 parent 345b902
commit 2dd817d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/controller.go b/controller.go
@@ -331,7 +331,7 @@ func (c *Controller) processPendingJobs() {
 	}
 	for _, job := range jobs {
 		listener, ok := c.listeners[job.Listener]
-		if !ok {
+		if !ok || listener.IsDisabled() {
 			continue
 		}
 		if job.Type == CallbackHandler && job.Method == "" {