We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9664bcc commit 63fe1f3Copy full SHA for 63fe1f3
omniqueue/src/backends/redis/streams.rs
@@ -336,7 +336,7 @@ async fn send_to_dlq<R: RedisConnection>(
336
.await
337
.map_err(QueueError::generic)?;
338
339
- let payload = ids.first().take().ok_or_else(|| QueueError::NoData)?;
+ let payload = ids.first().ok_or_else(|| QueueError::NoData)?;
340
let payload: Vec<u8> = payload
341
.map
342
.get(payload_key)
0 commit comments