diff options
Diffstat (limited to 'server/lib/activitypub/send/shared/send-utils.ts')
-rw-r--r-- | server/lib/activitypub/send/shared/send-utils.ts | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/server/lib/activitypub/send/shared/send-utils.ts b/server/lib/activitypub/send/shared/send-utils.ts index fcec63991..2bc1ef8f5 100644 --- a/server/lib/activitypub/send/shared/send-utils.ts +++ b/server/lib/activitypub/send/shared/send-utils.ts | |||
@@ -120,7 +120,7 @@ async function forwardActivity ( | |||
120 | body: activity, | 120 | body: activity, |
121 | contextType: null | 121 | contextType: null |
122 | } | 122 | } |
123 | return afterCommitIfTransaction(t, () => JobQueue.Instance.createJob({ type: 'activitypub-http-broadcast', payload })) | 123 | return afterCommitIfTransaction(t, () => JobQueue.Instance.createJobAsync({ type: 'activitypub-http-broadcast', payload })) |
124 | } | 124 | } |
125 | 125 | ||
126 | // --------------------------------------------------------------------------- | 126 | // --------------------------------------------------------------------------- |
@@ -205,7 +205,7 @@ function broadcastTo (options: { | |||
205 | contextType | 205 | contextType |
206 | } | 206 | } |
207 | 207 | ||
208 | JobQueue.Instance.createJob({ | 208 | JobQueue.Instance.createJobAsync({ |
209 | type: parallelizable | 209 | type: parallelizable |
210 | ? 'activitypub-http-broadcast-parallel' | 210 | ? 'activitypub-http-broadcast-parallel' |
211 | : 'activitypub-http-broadcast', | 211 | : 'activitypub-http-broadcast', |
@@ -222,7 +222,7 @@ function broadcastTo (options: { | |||
222 | contextType | 222 | contextType |
223 | } | 223 | } |
224 | 224 | ||
225 | JobQueue.Instance.createJob({ type: 'activitypub-http-unicast', payload }) | 225 | JobQueue.Instance.createJobAsync({ type: 'activitypub-http-unicast', payload }) |
226 | } | 226 | } |
227 | } | 227 | } |
228 | 228 | ||
@@ -243,7 +243,7 @@ function unicastTo (options: { | |||
243 | contextType | 243 | contextType |
244 | } | 244 | } |
245 | 245 | ||
246 | JobQueue.Instance.createJob({ type: 'activitypub-http-unicast', payload }) | 246 | JobQueue.Instance.createJobAsync({ type: 'activitypub-http-unicast', payload }) |
247 | } | 247 | } |
248 | 248 | ||
249 | // --------------------------------------------------------------------------- | 249 | // --------------------------------------------------------------------------- |