diff --git a/syncapi/syncapi.go b/syncapi/syncapi.go
index 1dcf3118f..762f4e9d3 100644
--- a/syncapi/syncapi.go
+++ b/syncapi/syncapi.go
@@ -81,7 +81,7 @@ func SetupSyncAPIComponent(
 		logrus.WithError(err).Panicf("failed to start typing consumer")
 	}
 
-	sendToDeviceConsumer := consumers.NewOutputClientDataConsumer(
+	sendToDeviceConsumer := consumers.NewOutputSendToDeviceEventConsumer(
 		base.Cfg, base.KafkaConsumer, notifier, syncDB,
 	)
 	if err = sendToDeviceConsumer.Start(); err != nil {