go/starter
1
0
Fork 0
mirror of https://github.com/ManyakRus/starter.git synced 2025-11-24 22:53:52 +02:00
Code Issues Releases Activity

сделал err = Connect_err()

Browse Source
This commit is contained in:
Nikitin Aleksandr
2025-04-30 14:47:33 +03:00
parent 10493066cb
commit 88c245e164
1 changed files with 11 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
camunda_connect/camunda_connect.go
View File

@@ -346,7 +346,17 @@ loop:
} else if NeedReconnect == true { } else if NeedReconnect == true {
log.Warn("CAMUNDA CheckPort(", addr, ") OK. Start Reconnect()") log.Warn("CAMUNDA CheckPort(", addr, ") OK. Start Reconnect()")
NeedReconnect = false 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() JobWorker = Client.NewJobWorker().JobType(CAMUNDA_JOBTYPE).Handler(HandleJob).Open()
} }
} }