diff --git a/apps/admin-gateway/src/module.api/payment.controller.ts b/apps/admin-gateway/src/module.api/payment.controller.ts index 154fcd3f..0d188a58 100644 --- a/apps/admin-gateway/src/module.api/payment.controller.ts +++ b/apps/admin-gateway/src/module.api/payment.controller.ts @@ -55,7 +55,7 @@ export class PaymentController { data: undefined } return await lastValueFrom( - this.paymentClient.send(QUEUE_MESSAGE.WALLET_UPDATE_PAYOUT, payload).pipe( + this.paymentClient.emit(QUEUE_MESSAGE.WALLET_UPDATE_PAYOUT, payload).pipe( catchError((error: IRpcException) => { throw new HttpException(error.message, error.status) })