From a021a9e332a73163ad15b8adc606aab9df8a13e6 Mon Sep 17 00:00:00 2001 From: Cedric Verstraeten Date: Thu, 20 Oct 2022 21:31:56 +0200 Subject: [PATCH] broke the pre recording when setting substream --- machinery/src/components/Kerberos.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/machinery/src/components/Kerberos.go b/machinery/src/components/Kerberos.go index 85847a4..c51dca9 100644 --- a/machinery/src/components/Kerberos.go +++ b/machinery/src/components/Kerberos.go @@ -132,8 +132,8 @@ func RunAgent(configuration *models.Configuration, communication *models.Communi if subStreamEnabled { log.Log.Info("RunAgent: Creating sub stream queue with SetMaxGopCount set to " + strconv.Itoa(int(config.Capture.PreRecording))) subQueue = pubsub.NewQueue() - queue.SetMaxGopCount(1) - queue.WriteHeader(subStreams) + subQueue.SetMaxGopCount(1) + subQueue.WriteHeader(subStreams) } // Configure a MQTT client which helps for a bi-directional communication