Merge branch 'develop'

kerberos-io · Oct 20, 2022 · e5c71bb · e5c71bb
2 parents bb18fff + a021a9e
commit e5c71bb
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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