From 9fbb193847d49a0c5926565216f698a6c67b715c Mon Sep 17 00:00:00 2001 From: Asia Date: Tue, 21 May 2024 11:04:40 +0200 Subject: [PATCH] Forwarder: set static channel name in AppSync mapper --- src/forward/mappers.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/forward/mappers.go b/src/forward/mappers.go index 638bd3e7..11521c61 100644 --- a/src/forward/mappers.go +++ b/src/forward/mappers.go @@ -46,6 +46,8 @@ func appSyncMapper(config *config.Config, channelName string, forContract bool) return task.NewMapper[*Payload, *publisher.AppSyncPayload[*model.InteractionNotification]](config, "map-appsync-notification"). WithWorkerPool(1, config.Contract.StoreBatchSize). WithProcessFunc(func(data *Payload, out chan *publisher.AppSyncPayload[*model.InteractionNotification]) (err error) { + channelName := channelName + // Neglect empty messages if data.Interaction == nil { return nil