diff --git a/controllers/webhookController.go b/controllers/webhookController.go
index 30e18d2..f1ae528 100644
--- a/controllers/webhookController.go
+++ b/controllers/webhookController.go
@@ -28,6 +28,11 @@ func ServerStart(c *fiber.Ctx) error {
 	return c.SendString("Server started: " + string(c.Body()))
 }
 
+func OnRtmpConnect(c *fiber.Ctx) error {
+	utils.PrettyPrintJson(c.Body())
+	return c.SendString("On_Rtmp_Connect: " + string(c.Body()))
+}
+
 func OnUpdate(c *fiber.Ctx) error {
 	p := new(models.Update)
 	if err := c.BodyParser(p); err != nil {
diff --git a/routes/routes.go b/routes/routes.go
index 4b1fc05..26d169a 100644
--- a/routes/routes.go
+++ b/routes/routes.go
@@ -24,6 +24,7 @@ func Setup(app *fiber.App) {
 
 	// Webhooks
 	app.Post("/on_server_start", controllers.ServerStart)
+	app.Post("/on_rtmp_connect", controllers.OnRtmpConnect)
 	app.Post("/on_update", controllers.OnUpdate)
 	app.Post("/on_pub_start", controllers.OnPubStart)
 	app.Post("/on_pub_stop", controllers.OnPubStop)