diff --git a/libsession/src/main/java/org/session/libsession/messaging/jobs/JobQueue.kt b/libsession/src/main/java/org/session/libsession/messaging/jobs/JobQueue.kt index a15ae3fb45..874ce6e0cc 100644 --- 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) } } }