From ba6e55ecf594ceacf78b1a638625d5d58589fa62 Mon Sep 17 00:00:00 2001 From: Neil Alexander Date: Wed, 27 May 2020 15:04:06 +0100 Subject: [PATCH] Start the send-to-device consumer --- syncapi/syncapi.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 {