update

app.js

@@ -13,7 +13,7 @@ class AppBootHook {
     const ctx = await this.app.createAnonymousContext();
     ctx.service.util.install.init();
     // 初始化死信机制
-    // ctx.service.util.rabbitMq.initDeadProcess();
+    ctx.service.util.rabbitMq.initDeadProcess();
     // await ctx.service.util.rabbitMq.mission();
   }
 }

app/service/util/rabbitMq.js

@@ -78,9 +78,7 @@ class RabbitmqService extends Service {
       for (const s of arr) {
         ser = ser[s];
       }
-      const m = _.get(ser, method);
-      if (!_.isFunction(m)) return;
-      m(params);
+      ser[method](params);
     } catch (error) {
       console.log(error);
     }