From 2beb2452f27db1599e64465ab76e1b654ad4438b Mon Sep 17 00:00:00 2001
From: gsavvas <gsavvas@existanze.com>
Date: Fri, 24 May 2024 15:25:17 +0300
Subject: [PATCH] Add acceptance handling and fix reconnect issue of consumer

Change-Id: If5bcf1fd88d1b1e0ec4af4a7af5d091df5345a6f
---
 .../eu/nebulouscloud/exn/core/Consumer.groovy | 24 ++++++++++++-------
 1 file changed, 16 insertions(+), 8 deletions(-)

diff --git a/exn-connector/src/main/groovy/eu/nebulouscloud/exn/core/Consumer.groovy b/exn-connector/src/main/groovy/eu/nebulouscloud/exn/core/Consumer.groovy
index 4f16ac7..1424c65 100644
--- a/exn-connector/src/main/groovy/eu/nebulouscloud/exn/core/Consumer.groovy
+++ b/exn-connector/src/main/groovy/eu/nebulouscloud/exn/core/Consumer.groovy
@@ -74,14 +74,22 @@ class Consumer extends Link<Receiver>{
         Message message = delivery.message();
 
         Map body = this.processMessage(message, context)
-        this.handler.onMessage(
-                this.key,
-                this.address,
-                body,
-                message,
-                context
-        )
-        delivery.accept()
+        try {
+            this.handler.onMessage(
+                    this.key,
+                    this.address,
+                    body,
+                    message,
+                    context
+            )
+            delivery.accept()
+        }catch (Exception e){
+            if(!delivery.state().isAccepted()){
+                delivery.reject('Generic onMessage error',e.message)
+            }
+            logger.error('Generic onMessage error',e)
+        }
+
     }
 
 }