Skip to content

Commit a1eed7c

Browse files
committed
chore: update messaging-redis-extension dependency
1 parent 5d7fa1e commit a1eed7c

File tree

3 files changed

+25
-19
lines changed

3 files changed

+25
-19
lines changed

package-lock.json

Lines changed: 17 additions & 17 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,7 @@
7373
"@nestjs/swagger": "11.2.0",
7474
"@nestjs/terminus": "^11.0.0",
7575
"@nestjstools/messaging": "^2.21.1",
76-
"@nestjstools/messaging-redis-extension": "^1.2.2",
76+
"@kastov/messaging-redis-extension": "1.2.3",
7777
"@peculiar/webcrypto": "^1.5.0",
7878
"@peculiar/x509": "^1.13.0",
7979
"@prisma/adapter-pg": "^6.10.1",

src/integration-modules/messaging-modules.ts

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,8 @@
11
import {
22
MessagingRedisExtensionModule,
33
RedisChannelConfig,
4-
} from '@nestjstools/messaging-redis-extension';
4+
} from '@kastov/messaging-redis-extension';
5+
56
import { MessagingModule } from '@nestjstools/messaging';
67
import { ConfigService } from '@nestjs/config';
78
import { ConfigModule } from '@nestjs/config';
@@ -27,6 +28,11 @@ import { MessagingBuses, MessagingChannels, MessagingQueues } from '@libs/contra
2728
new RedisChannelConfig({
2829
name: MessagingChannels.EVENT,
2930
queue: MessagingQueues.EVENT,
31+
bullJobOptions: {
32+
removeOnComplete: 50,
33+
removeOnFail: 50,
34+
},
35+
3036
connection: {
3137
host: configService.getOrThrow<string>('REDIS_HOST'),
3238
port: configService.getOrThrow<number>('REDIS_PORT'),

0 commit comments

Comments
 (0)