Skip to content

Commit 1b16718

Browse files
committed
fix: add forceParse option to mqRSSAdd for on-demand queue processing
1 parent 6c63f3e commit 1b16718

1 file changed

Lines changed: 9 additions & 5 deletions

File tree

src/controllers/mq/mq.ts

Lines changed: 9 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -31,11 +31,15 @@ export class MQController {
3131

3232
try {
3333
const mqConstantMessageOptions = MQ_QUEUES['rss-on-demand'];
34-
await mqRSSAdd(activeMQArtemisService, {
35-
...mqConstantMessageOptions,
36-
feedUrl: finalDto.url,
37-
podcast_index_id: finalDto.podcast_index_id
38-
});
34+
await mqRSSAdd(
35+
activeMQArtemisService,
36+
{
37+
...mqConstantMessageOptions,
38+
feedUrl: finalDto.url,
39+
podcast_index_id: finalDto.podcast_index_id,
40+
},
41+
{ forceParse: true }
42+
);
3943
res.status(201).json({ message: "Feed added to on-demand queue successfully." });
4044
} catch (err) {
4145
handleGenericErrorResponse(res, err);

0 commit comments

Comments
 (0)