kerberos-io/agent
1
0
Fork 0
mirror of https://github.com/kerberos-io/agent.git synced 2026-10-19 17:38:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'develop'

Browse Source
This commit is contained in:
Cedric Verstraeten
2022-10-20 21:32:12 +02:00
parent bb18fff7d9 a021a9e332
commit e5c71bb6b2
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
machinery/src/components/Kerberos.go
+2 -2
View File
@@ -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