fix(workflow-engine-redis): module option queueName wrongly used (#13570)
https://github.com/medusajs/medusa/issues/13452 **What** Wrongly used module option for redis workflow engine
This commit is contained in:
@@ -0,0 +1,5 @@
|
|||||||
|
---
|
||||||
|
"@medusajs/workflow-engine-redis": patch
|
||||||
|
---
|
||||||
|
|
||||||
|
fix(workflow-engine-redis): module option queueName wrongly used
|
||||||
@@ -13,6 +13,8 @@ export default async (
|
|||||||
const {
|
const {
|
||||||
url,
|
url,
|
||||||
options: redisOptions,
|
options: redisOptions,
|
||||||
|
jobQueueName,
|
||||||
|
queueName,
|
||||||
pubsub,
|
pubsub,
|
||||||
} = options?.redis as RedisWorkflowsOptions
|
} = options?.redis as RedisWorkflowsOptions
|
||||||
|
|
||||||
@@ -25,8 +27,8 @@ export default async (
|
|||||||
|
|
||||||
const cnnPubSub = pubsub ?? { url, options: redisOptions }
|
const cnnPubSub = pubsub ?? { url, options: redisOptions }
|
||||||
|
|
||||||
const queueName = options?.queueName ?? "medusa-workflows"
|
const queueName_ = queueName ?? "medusa-workflows"
|
||||||
const jobQueueName = options?.jobQueueName ?? "medusa-workflows-jobs"
|
const jobQueueName_ = jobQueueName ?? "medusa-workflows-jobs"
|
||||||
|
|
||||||
let connection
|
let connection
|
||||||
let redisPublisher
|
let redisPublisher
|
||||||
@@ -67,8 +69,8 @@ export default async (
|
|||||||
redisWorkerConnection: asValue(workerConnection),
|
redisWorkerConnection: asValue(workerConnection),
|
||||||
redisPublisher: asValue(redisPublisher),
|
redisPublisher: asValue(redisPublisher),
|
||||||
redisSubscriber: asValue(redisSubscriber),
|
redisSubscriber: asValue(redisSubscriber),
|
||||||
redisQueueName: asValue(queueName),
|
redisQueueName: asValue(queueName_),
|
||||||
redisJobQueueName: asValue(jobQueueName),
|
redisJobQueueName: asValue(jobQueueName_),
|
||||||
redisDisconnectHandler: asValue(async () => {
|
redisDisconnectHandler: asValue(async () => {
|
||||||
connection.disconnect()
|
connection.disconnect()
|
||||||
workerConnection.disconnect()
|
workerConnection.disconnect()
|
||||||
|
|||||||
Reference in New Issue
Block a user