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++