tested rabbitmq

Signed-off-by: yuvraj <evalsocket@gmail.com>
falcosecurity · Mar 26, 2021 · 9895bea · 9895bea
1 parent e80cee9
commit 9895bea
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/handlers.go b/handlers.go
@@ -229,6 +229,10 @@ func forwardEvent(falcopayload types.FalcoPayload) {
 		go openfaasClient.OpenfaasCall(falcopayload)
 	}
 
+	if config.Rabbitmq.URL != "" && config.Rabbitmq.Queue != "" && (falcopayload.Priority >= types.Priority(config.Openfaas.MinimumPriority) || falcopayload.Rule == testRule) {
+		go rabbitmqClient.Publish(falcopayload)
+	}
+
 	if config.WebUI.URL != "" {
 		go webUIClient.WebUIPost(falcopayload)
 	}