From 9fef876f5b84619541b8e24685093bf4b01909cd Mon Sep 17 00:00:00 2001
From: Vladislav Grishenko <themiron@yandex-team.ru>
Date: Thu, 14 Sep 2023 22:50:21 +0500
Subject: [PATCH] Fix mq producer channel leak

MQ channel is not being closed on shutdown, so producer loop can't
be exitied and no graceful shutdown can be performed.

Signed-off-by: Vladislav Grishenko <themiron@yandex-team.ru>
---
 vflow/ipfix.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/vflow/ipfix.go b/vflow/ipfix.go
index a5e49a2b..1a80a20e 100644
--- a/vflow/ipfix.go
+++ b/vflow/ipfix.go
@@ -187,6 +187,7 @@ func (i *IPFIX) shutdown() {
 	// logging and close UDP channel
 	logger.Println("ipfix has been shutdown")
 	close(ipfixUDPCh)
+	close(ipfixMQCh)
 }
 
 func (i *IPFIX) ipfixWorker(wQuit chan struct{}) {