From 88c245e164f3af82c0e1af71c58652afb44d4d59 Mon Sep 17 00:00:00 2001
From: Nikitin Aleksandr <nikitinav@atomsbt.ru>
Date: Wed, 30 Apr 2025 14:47:33 +0300
Subject: [PATCH] =?UTF-8?q?=D1=81=D0=B4=D0=B5=D0=BB=D0=B0=D0=BB=20err=20?=
 =?UTF-8?q?=3D=20Connect=5Ferr()?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 camunda_connect/camunda_connect.go | 12 +++++++++++-
 1 file changed, 11 insertions(+), 1 deletion(-)

diff --git a/camunda_connect/camunda_connect.go b/camunda_connect/camunda_connect.go
index 03368d68..0b0bab5d 100644
--- a/camunda_connect/camunda_connect.go
+++ b/camunda_connect/camunda_connect.go
@@ -346,7 +346,17 @@ loop:
 			} else if NeedReconnect == true {
 				log.Warn("CAMUNDA CheckPort(", addr, ") OK. Start Reconnect()")
 				NeedReconnect = false
-				Connect()
+				err = Connect_err()
+				if err != nil {
+					NeedReconnect = true
+					log.Error("Connect_err() error: ", err)
+					break
+				}
+
+				//новый JobWorker
+				if JobWorker != nil {
+					JobWorker.Close()
+				}
 				JobWorker = Client.NewJobWorker().JobType(CAMUNDA_JOBTYPE).Handler(HandleJob).Open()
 			}
 		}