v.0.0.3.2

server.go

@@ -429,8 +429,8 @@ func (s *server) runStream(req *proto.StreamMessagesRequest, stream proto.Messag
 				d.Nack(false, true) // Возвращаем в очередь при ошибке отправки
 				return err
 			}
+			d.Ack(false)
 
-			d.Ack(false) // Подтверждаем обработку
 		}
 	}
 }
@@ -475,7 +475,7 @@ func main() {
 			// Попытка переподключения
 			for i := 0; i < 5; i++ {
 				time.Sleep(time.Second * time.Duration(i+1))
-				newConn, err := amqp.Dial("amqp://tailly_rabbitmq:o2p2S80MPbl27LUU@89.104.69.222:5673/")
+				newConn, err := amqp.Dial("amqp://...")
 				if err == nil {
 					mu.Lock()
 					*conn = newConn