diff --git a/deployment/develop/jenkinsfile.groovy b/deployment/develop/jenkinsfile.groovy index 4acd4a5..a794de9 100644 --- a/deployment/develop/jenkinsfile.groovy +++ b/deployment/develop/jenkinsfile.groovy @@ -56,7 +56,7 @@ pipeline { ), sshTransfer( cleanRemote: false, - execCommand: "ln -sf $BASE_REMOTE_PATH/vault/savefamily/sf-sims/wsaccess_alaisecure_com_cert_client_new.p12 $APP_REMOTE_PATH/packages/wsaccess_alaisecure_com_cert_client_new.p12 + execCommand: "ln -sf $BASE_REMOTE_PATH/vault/savefamily/sf-sims/wsaccess_alaisecure_com_cert_client_new.p12 $APP_REMOTE_PATH/packages/wsaccess_alaisecure_com_cert_client_new.p12" ), sshTransfer( cleanRemote: false, diff --git a/packages/sim-shared/infrastructure/RabbitMQEventBus.ts b/packages/sim-shared/infrastructure/RabbitMQEventBus.ts index b6ef8d5..833d7c9 100644 --- a/packages/sim-shared/infrastructure/RabbitMQEventBus.ts +++ b/packages/sim-shared/infrastructure/RabbitMQEventBus.ts @@ -51,9 +51,14 @@ export class RabbitMQEventBus implements EventBus { } /** - * TODO: - * - Esta implementacion del nack debe estar en objenious - */ + * Re-implementacion del nack con chequeo del numero de reinetentos. + * TODO: + * - Decidir si se chequean o no los reintentos con errores 429 + * - Motivo del Ășltimo error en el mensaje + * + * @param msg + * @param requeue + */ async nack(msg: ConsumeMessage, requeue?: boolean) { if (this.channel == undefined) throw new Error("[RMQ] Canal no iniciallizado"); @@ -82,9 +87,7 @@ export class RabbitMQEventBus implements EventBus { }) } - // Hace falta? this.channel.ack(msg) - //return this.channel.nack(msg, false, requeue) }