Skip to content

Commit 059eae2

Browse files
committed
fix: string parsing on messages
1 parent 63b5de9 commit 059eae2

File tree

1 file changed

+6
-5
lines changed

1 file changed

+6
-5
lines changed

src/com/moclojer/rq/queue.clj

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -133,7 +133,7 @@
133133
(let [{:keys [pattern]
134134
:or {pattern :rq} :as opts} options
135135
packed-queue-name (utils/pack-pattern pattern queue-name)
136-
encoded-message (str (clojure.edn/read-string (str message)))
136+
encoded-message (pr-str message)
137137
return (.lset @client packed-queue-name index encoded-message)]
138138

139139
(log/debug "set in queue"
@@ -160,12 +160,13 @@
160160
(let [{:keys [pattern]
161161
:or {pattern :rq}} options
162162
packed-queue-name (utils/pack-pattern pattern queue-name)
163-
return (.lrem @client packed-queue-name cnt (str msg))]
163+
encoded-message (pr-str msg)
164+
return (.lrem @client packed-queue-name cnt encoded-message)]
164165

165166
(log/debug "removed from queue"
166167
{:client client
167168
:queue-name queue-name
168-
:msg (clojure.edn/read-string (str msg))
169+
:msg msg
169170
:count cnt
170171
:return return})
171172
return))
@@ -187,8 +188,8 @@
187188
:or {pos :before
188189
pattern :rq} :as opts} options
189190
packed-queue-name (utils/pack-pattern pattern queue-name)
190-
encoded-message (str (clojure.edn/read-string (str msg)))
191-
encoded-pivot (str (clojure.edn/read-string (str pivot)))
191+
encoded-message (pr-str msg)
192+
encoded-pivot (pr-str pivot)
192193
encoded-pos (if (= pos :before)
193194
redis.clients.jedis.args.ListPosition/BEFORE
194195
redis.clients.jedis.args.ListPosition/AFTER)

0 commit comments

Comments
 (0)