From 2b2fced914d5f546f02eda92b19c5d93d003a566 Mon Sep 17 00:00:00 2001 From: Valentin Yanakiev Date: Thu, 11 Nov 2021 11:41:23 +0200 Subject: [PATCH 1/2] Ack fix --- src/app.controller.ts | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/src/app.controller.ts b/src/app.controller.ts index e8bf38eb..587adf6c 100644 --- a/src/app.controller.ts +++ b/src/app.controller.ts @@ -40,11 +40,16 @@ export class AppController { if (nacked.length === 0) { this.logger.verbose?.(`All ${x.length} messages successfully sent!`); + channel.ack(originalMsg); } else { this.logger.verbose?.(`${nacked.length} messages failed to be sent!`); + //channel.nack(originalMsg); + channel.ack(originalMsg); } }) .catch(err => { + //channel.reject(originalMsg); + channel.ack(originalMsg); this.logger.error(err); }); } From 199eed195cab89cd9af0312d2272d6c1234918cf Mon Sep 17 00:00:00 2001 From: Valentin Yanakiev Date: Thu, 11 Nov 2021 11:45:57 +0200 Subject: [PATCH 2/2] Updated version to 0.3.2 --- package-lock.json | 4 ++-- package.json | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/package-lock.json b/package-lock.json index 7ecf5949..b421cf96 100644 --- a/package-lock.json +++ b/package-lock.json @@ -1,12 +1,12 @@ { "name": "alkemio-notifications", - "version": "0.3.1", + "version": "0.3.2", "lockfileVersion": 2, "requires": true, "packages": { "": { "name": "alkemio-notifications", - "version": "0.3.1", + "version": "0.3.2", "license": "EUPL-1.2", "dependencies": { "@alkemio/client-lib": "^0.10.1", diff --git a/package.json b/package.json index 0b634b74..d7d97664 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "alkemio-notifications", - "version": "0.3.1", + "version": "0.3.2", "description": "Alkemio notifications service", "author": "Cherrytwist Foundation", "private": false,