From b75b6c2a4964aa939498ecd4d10e8c809fa86978 Mon Sep 17 00:00:00 2001
From: Rob <robacarp@users.noreply.github.com>
Date: Fri, 15 Nov 2024 17:39:01 -0700
Subject: [PATCH] Create ye_olde_redis.cr

fixes #132

Require this file in application startup to revert to the old behavior for redis servers pre 6.2.
---
 src/ye_olde_redis.cr | 11 +++++++++++
 1 file changed, 11 insertions(+)
 create mode 100644 src/ye_olde_redis.cr

diff --git a/src/ye_olde_redis.cr b/src/ye_olde_redis.cr
new file mode 100644
index 0000000..095ff12
--- /dev/null
+++ b/src/ye_olde_redis.cr
@@ -0,0 +1,11 @@
+# Monkeypatch to revert to the old Redis behavior, for Redis servers pre 6.2 which don't support
+# https://redis.io/docs/latest/commands/lmove/
+module Mosquito
+  class RedisBackend < Mosquito::Backend
+    def dequeue : JobRun?
+      if id = redis.rpoplpush waiting_q, pending_q
+        JobRun.retrieve id.to_s
+      end
+    end
+  end
+end