From 54302d3bdaec42f476af2378e986ddc4c893c1a3 Mon Sep 17 00:00:00 2001
From: Alexey Khit <alexey.khit@gmail.com>
Date: Sat, 25 Mar 2023 07:36:21 +0300
Subject: [PATCH] Fix json locked

---
 cmd/streams/producer.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/cmd/streams/producer.go b/cmd/streams/producer.go
index 3c86961e..1af588fe 100644
--- a/cmd/streams/producer.go
+++ b/cmd/streams/producer.go
@@ -171,7 +171,8 @@ func (p *Producer) reconnect(workerID int) {
 
 	log.Debug().Msgf("[streams] reconnect to url=%s", p.url)
 
-	if err := p.Dial(); err != nil {
+	var err error
+	if p.conn, err = GetProducer(p.url); err != nil {
 		log.Debug().Msgf("[streams] producer=%s", err)
 		// TODO: dynamic timeout
 		time.AfterFunc(30*time.Second, func() {