Skip to content
This repository was archived by the owner on Jul 4, 2025. It is now read-only.

Commit 5b5b5a7

Browse files
dahliaclaude
andcommitted
Add enqueueMany() method to RedisMessageQueue
Implements the enqueueMany method interface from Fedify 1.5.0 for more efficient bulk message insertion using Redis transactions. Co-Authored-By: Claude <[email protected]>
1 parent a34d388 commit 5b5b5a7

File tree

7 files changed

+512
-480
lines changed

7 files changed

+512
-480
lines changed

.github/workflows/main.yaml

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -19,9 +19,9 @@ jobs:
1919
- 6379:6379
2020
steps:
2121
- uses: actions/checkout@v4
22-
- uses: denoland/setup-deno@v1
22+
- uses: denoland/setup-deno@v2
2323
with:
24-
deno-version: v1.x
24+
deno-version: v2.x
2525
- uses: actions/setup-node@v4
2626
with:
2727
node-version: lts/*
@@ -47,9 +47,9 @@ jobs:
4747
id-token: write
4848
steps:
4949
- uses: actions/checkout@v4
50-
- uses: denoland/setup-deno@v1
50+
- uses: denoland/setup-deno@v2
5151
with:
52-
deno-version: v1.x
52+
deno-version: v2.x
5353
- uses: actions/setup-node@v4
5454
with:
5555
node-version: lts/*

README.md

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -66,6 +66,9 @@ Changelog
6666

6767
To be released.
6868

69+
- Added `RedisMessageQueue.enqueueMany()` method for efficiently enqueueing
70+
multiple messages in a single transaction.
71+
6972
### Version 0.3.0
7073

7174
Released on October 4, 2024.

deno.json

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,8 +10,8 @@
1010
},
1111
"imports": {
1212
"@deno/dnt": "jsr:@deno/dnt@^0.41.3",
13-
"@fedify/fedify": "jsr:@fedify/fedify@^1.0.0",
14-
"@logtape/logtape": "jsr:@logtape/logtape@^0.6.3",
13+
"@fedify/fedify": "jsr:@fedify/fedify@1.5.0-dev.732+7b169275",
14+
"@logtape/logtape": "jsr:@logtape/logtape@^0.9.0",
1515
"@std/assert": "jsr:@std/assert@^0.226.0",
1616
"@std/async": "jsr:@std/async@^0.224.2",
1717
"ioredis": "npm:ioredis@^5.4.1"
@@ -20,6 +20,9 @@
2020
"temporal"
2121
],
2222
"exclude": [
23+
".github",
24+
".vscode",
25+
".zed",
2326
"npm"
2427
],
2528
"tasks": {

0 commit comments

Comments
 (0)