From a38dcb28b8e261d1205e1a1dd7ffaf1e66def48c Mon Sep 17 00:00:00 2001 From: Nikitin Aleksandr Date: Thu, 16 Jan 2025 16:40:58 +0300 Subject: [PATCH] =?UTF-8?q?=D1=81=D0=B4=D0=B5=D0=BB=D0=B0=D0=BB=20camunda?= =?UTF-8?q?=5Fconnect?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- camunda_connect/camunda_connect.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/camunda_connect/camunda_connect.go b/camunda_connect/camunda_connect.go index 284421a3..bea2238d 100644 --- a/camunda_connect/camunda_connect.go +++ b/camunda_connect/camunda_connect.go @@ -264,7 +264,7 @@ func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup, HandleJob func(c go WaitStop() stopapp.GetWaitGroup_Main().Add(1) - go ping_go() + go ping_go(HandleJob, CAMUNDA_JOBTYPE) return err } @@ -298,7 +298,7 @@ func Send_BPMN_File(BPMN_filename string) { } // ping_go - делает пинг каждые 60 секунд, и реконнект -func ping_go() { +func ping_go(HandleJob func(client worker.JobClient, job entities.Job), CAMUNDA_JOBTYPE string) { ticker := time.NewTicker(60 * time.Second) @@ -321,6 +321,7 @@ loop: log.Warn("CAMUNDA CheckPort(", addr, ") OK. Start Reconnect()") NeedReconnect = false Connect() + JobWorker = Client.NewJobWorker().JobType(CAMUNDA_JOBTYPE).Handler(HandleJob).Open() } } }