@@ -25,7 +25,16 @@ import { getNoteSummary } from '@/misc/get-note-summary.js';
25
25
import { DI } from '@/di-symbols.js' ;
26
26
import * as Acct from '@/misc/acct.js' ;
27
27
import { MetaService } from '@/core/MetaService.js' ;
28
- import type { DbQueue , DeliverQueue , EndedPollNotificationQueue , InboxQueue , ObjectStorageQueue , SystemQueue , WebhookDeliverQueue } from '@/core/QueueModule.js' ;
28
+ import type {
29
+ DbQueue ,
30
+ DeliverQueue ,
31
+ EndedPollNotificationQueue ,
32
+ InboxQueue ,
33
+ ObjectStorageQueue ,
34
+ RelationshipQueue ,
35
+ SystemQueue ,
36
+ WebhookDeliverQueue ,
37
+ } from '@/core/QueueModule.js' ;
29
38
import { UserEntityService } from '@/core/entities/UserEntityService.js' ;
30
39
import { NoteEntityService } from '@/core/entities/NoteEntityService.js' ;
31
40
import { PageEntityService } from '@/core/entities/PageEntityService.js' ;
@@ -110,6 +119,7 @@ export class ClientServerService {
110
119
@Inject ( 'queue:deliver' ) public deliverQueue : DeliverQueue ,
111
120
@Inject ( 'queue:inbox' ) public inboxQueue : InboxQueue ,
112
121
@Inject ( 'queue:db' ) public dbQueue : DbQueue ,
122
+ @Inject ( 'queue:relationship' ) public relationshipQueue : RelationshipQueue ,
113
123
@Inject ( 'queue:objectStorage' ) public objectStorageQueue : ObjectStorageQueue ,
114
124
@Inject ( 'queue:webhookDeliver' ) public webhookDeliverQueue : WebhookDeliverQueue ,
115
125
) {
@@ -237,6 +247,7 @@ export class ClientServerService {
237
247
this . endedPollNotificationQueue ,
238
248
this . inboxQueue ,
239
249
this . dbQueue ,
250
+ this . relationshipQueue ,
240
251
this . objectStorageQueue ,
241
252
this . webhookDeliverQueue ,
242
253
] . map ( q => new BullMQAdapter ( q ) )
0 commit comments