From f7ffd8e8bdab65d95df44d986d9ee1db6ec9a9b6 Mon Sep 17 00:00:00 2001
From: liquidz <liquidz.uo@gmail.com>
Date: Tue, 9 Aug 2022 07:31:58 +0900
Subject: [PATCH 1/2] fix: Fix respond/raise not to take extra signs

---
 src/gluttony/record/consumer.clj | 40 ++++++++++++++++++--------------
 test/gluttony/core_test.clj      |  2 ++
 2 files changed, 24 insertions(+), 18 deletions(-)

diff --git a/src/gluttony/record/consumer.clj b/src/gluttony/record/consumer.clj
index b02c218..11670d0 100644
--- a/src/gluttony/record/consumer.clj
+++ b/src/gluttony/record/consumer.clj
@@ -51,27 +51,31 @@
 
 (defn- respond*
   [{:keys [client queue-url consume-chan]} p message]
-  (deliver p :respond)
-  (a/go
-    (when consume-chan
-      ;; takes a sign and make a space in which next consume can work
-      (a/<! consume-chan)
-      (log/debugf "takes a sign of message-id:%s" (:message-id message)))
-    (a/<! (sqs/delete-message client {:queue-url queue-url
-                                      :receipt-handle (:receipt-handle message)}))))
+  (let [already-realized? (realized? p)]
+    (deliver p :respond)
+    (a/go
+      (when (and consume-chan
+                 (not already-realized?))
+        ;; takes a sign and make a space in which next consume can work
+        (a/<! consume-chan)
+        (log/debugf "takes a sign of message-id:%s" (:message-id message)))
+      (a/<! (sqs/delete-message client {:queue-url queue-url
+                                        :receipt-handle (:receipt-handle message)})))))
 
 (defn- raise*
   [{:keys [client queue-url consume-chan]} p message & [retry-delay]]
-  (deliver p :raise)
-  (a/go
-    (when consume-chan
-      ;; takes a sign and make a space in which next consume can work
-      (a/<! consume-chan)
-      (log/debugf "takes a sign of message-id:%s" (:message-id message)))
-    (let [retry-delay (or retry-delay 0)]
-      (a/<! (sqs/change-message-visibility client {:queue-url queue-url
-                                                   :receipt-handle (:receipt-handle message)
-                                                   :visibility-timeout retry-delay})))))
+  (let [already-realized? (realized? p)]
+    (deliver p :raise)
+    (a/go
+      (when (and consume-chan
+                 (not already-realized?))
+        ;; takes a sign and make a space in which next consume can work
+        (a/<! consume-chan)
+        (log/debugf "takes a sign of message-id:%s" (:message-id message)))
+      (let [retry-delay (or retry-delay 0)]
+        (a/<! (sqs/change-message-visibility client {:queue-url queue-url
+                                                     :receipt-handle (:receipt-handle message)
+                                                     :visibility-timeout retry-delay}))))))
 
 (defn- heartbeat*
   "When heartbeat parameter is set, a heartbeat process start after the first heartbeat"
diff --git a/test/gluttony/core_test.clj b/test/gluttony/core_test.clj
index 2c408bb..1912366 100644
--- a/test/gluttony/core_test.clj
+++ b/test/gluttony/core_test.clj
@@ -181,6 +181,8 @@
                           (a/<! (a/timeout 10))             ; Make a point of park
                           (swap! collected
                                  conj Integer/MIN_VALUE)
+                          (respond)
+                          ;; Respond twice on purpose
                           (respond)))
               consumer (start-consumer queue-url consume
                                        {:client th/client

From eae4bb097ca56085fa1b861127ac4669c9bcb40f Mon Sep 17 00:00:00 2001
From: liquidz <liquidz.uo@gmail.com>
Date: Tue, 9 Aug 2022 07:35:36 +0900
Subject: [PATCH 2/2] docs: Update changelog

---
 CHANGELOG.md | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/CHANGELOG.md b/CHANGELOG.md
index 788a7cd..561601b 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,6 +1,8 @@
 # Change Log
 
 ## [Unreleased]
+### Fixed
+* Fixed `respond` and `raise` not to take extra signs when these functions are called more than once.
 
 ## 0.4.87
 ### Changed