File tree Expand file tree Collapse file tree 2 files changed +8
-19
lines changed Expand file tree Collapse file tree 2 files changed +8
-19
lines changed Original file line number Diff line number Diff line change 98
98
:queue-name packed-queue-name
99
99
:options {:direction direction :pattern pattern}
100
100
:message message})
101
- (edn/read-string message)))))
102
-
101
+ (edn/read-string message)))))
103
102
104
103
(defn lindex
105
104
" Return a element in a specified index
194
193
redis.clients.jedis.args.ListPosition/BEFORE
195
194
redis.clients.jedis.args.ListPosition/AFTER)
196
195
return (.linsert @client packed-queue-name encoded-pos encoded-pivot encoded-message)]
197
- (log/debug " inserted in queue"
198
- {:client client
199
- :queue-name queue-name
200
- :msg encoded-message
201
- :opts opts
202
- :return return})
203
- return))
204
-
196
+ (log/debug " inserted in queue"
197
+ {:client client
198
+ :queue-name queue-name
199
+ :msg encoded-message
200
+ :opts opts
201
+ :return return})
202
+ return))
205
203
206
204
(defn lrange
207
205
" Return an entire range given min and max indexes
223
221
:result return})
224
222
(mapv clojure.edn/read-string return)))
225
223
226
-
227
224
(defn ltrim
228
225
" Trim a list to the specified range.
229
226
246
243
:result return})
247
244
return)))
248
245
249
-
250
-
251
246
(defn rpoplpush
252
247
" Remove the last element in a list and append it to another list.
253
248
270
265
:result return})
271
266
return))
272
267
273
-
274
268
(defn brpoplpush
275
269
" Remove the last element in a list and append it to another list, blocking if necessary.
276
270
295
289
:result result})
296
290
result))
297
291
298
-
299
-
300
292
(defn lmove
301
293
" Atomically return and remove the first/last element of the source list, and push the element as the first/last element of the destination list.
302
294
Original file line number Diff line number Diff line change 67
67
(rq-queue/pop! client queue-name :direction :l )
68
68
(rq-queue/pop! client queue-name :direction :l ))
69
69
70
-
71
70
(t/testing " lrange"
72
71
(rq-queue/push! client queue-name message)
73
72
(rq-queue/push! client queue-name another-message)
76
75
(rq-queue/pop! client queue-name :direction :l )
77
76
(rq-queue/pop! client queue-name :direction :l ))
78
77
79
-
80
78
(t/testing " ltrim"
81
79
(let [base-message {:test " hello" , :my/test2 " 123" , :foobar [" 321" ]}
82
80
message (assoc base-message :uuid (java.util.UUID/randomUUID ))
90
88
(rq-queue/pop! client queue-name :direction :l )
91
89
(rq-queue/pop! client queue-name :direction :l ))
92
90
93
-
94
91
(t/testing " rpoplpush"
95
92
(rq-queue/push! client queue-name message)
96
93
(rq-queue/rpoplpush client queue-name another-queue-name)
You can’t perform that action at this time.
0 commit comments