unoffical wafrn mirror
wafrn.net
atproto
social-network
activitypub
1import { Queue } from 'bullmq'
2import { completeEnvironment } from '../backendOptions.js'
3
4const sendPostBskyQueue = new Queue('sendPostBsky', {
5 connection: completeEnvironment.bullmqConnection,
6 defaultJobOptions: {
7 removeOnComplete: true,
8 attempts: 3,
9 backoff: {
10 type: 'fixed',
11 delay: 25000
12 },
13 removeOnFail: true
14 }
15})
16
17await sendPostBskyQueue.add('sendPostBsky', { postId: '7757193e-aba9-4cc7-abb8-91d818e6baef' })