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{}) {