fix: use queue in the retry timer

4 years ago · dd8a0cdc2e
parent fe3f3d5f88
commit dd8a0cdc2e
1 changed files with 1 additions and 1 deletions
--- a/libsession/src/main/java/org/session/libsession/messaging/jobs/JobQueue.kt
+++ b/libsession/src/main/java/org/session/libsession/messaging/jobs/JobQueue.kt
@ -80,7 +80,7 @@ class JobQueue : JobDelegate {
            Log.i("Jobs", "${job::class.simpleName} failed; scheduling retry (failure count is ${job.failureCount}).")
            Timer().schedule(delay = retryInterval) {
                Log.i("Jobs", "Retrying ${job::class.simpleName}.")
-                job.execute()
+                queue.offer(job)
            }
        }
    }