Fix bug wrong queueName on initAMQPActions

taina0407 · Apr 16, 2021 · 84bf8c8 · 84bf8c8
1 parent 085b7dc
commit 84bf8c8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/index.js b/src/index.js
@@ -145,6 +145,7 @@ const initAMQPActions = function (schema) {
  };
  }
 
+ const queueName = `amqp.${schema.version ? `v${schema.version}.` : ""}${schema.name}.${actionName}`;
  schema.actions[`${actionName}.async`] = {
  timeout: 10000,
  retryPolicy: {
@@ -153,7 +154,6 @@ const initAMQPActions = function (schema) {
  },
  params: asyncParams,
  async handler(ctx) {
- const queueName = `amqp.${ctx.params.action}`;
  const dedupeHash = Deep(this.$amqpOptions, [queueName, "options", "dedupHash"]);
  const headers = ctx.headers || {};
  if (typeof dedupeHash === "number" || typeof dedupeHash === "string") {