From bcc5eb35b6378afc52288eab0d28ff10b7cd22a4 Mon Sep 17 00:00:00 2001 From: postmannen Date: Wed, 22 Jun 2022 05:31:40 +0200 Subject: [PATCH] removed pub sleep which kept allocs for too long. --- process.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/process.go b/process.go index cf51f18..1340c59 100644 --- a/process.go +++ b/process.go @@ -307,7 +307,7 @@ func (p process) messageDeliverNats(natsMsgPayload []byte, natsMsgHeader nats.He // sendErrorLogMessage(p.toRingbufferCh, node(p.node), er) log.Printf("%v, waiting %ds before retrying\n", er, subscribeSyncTimer) - time.Sleep(time.Second * subscribeSyncTimer) + //time.Sleep(time.Second * subscribeSyncTimer) // subReply.Unsubscribe() retryAttempts++