From 82302f37517a949c3feca4f45c397ea384330e20 Mon Sep 17 00:00:00 2001 From: bene-tleilax-werdna <99219287+bene-tleilax-werdna@users.noreply.github.com> Date: Fri, 19 Apr 2024 16:34:27 -0400 Subject: [PATCH] fix(AzureQueueStorage): update base64 encoding (#3104) --- eventsources/sources/azurequeuestorage/start.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/eventsources/sources/azurequeuestorage/start.go b/eventsources/sources/azurequeuestorage/start.go index 2efda677d9..a548dfbfd8 100644 --- a/eventsources/sources/azurequeuestorage/start.go +++ b/eventsources/sources/azurequeuestorage/start.go @@ -137,7 +137,7 @@ func (el *EventListener) processMessage(message *azqueue.DequeuedMessage, dispat } body := []byte(*message.MessageText) if el.AzureQueueStorageEventSource.DecodeMessage { - rawDecodedText, err := base64.RawURLEncoding.DecodeString(*message.MessageText) + rawDecodedText, err := base64.URLEncoding.DecodeString(*message.MessageText) if err != nil { log.Errorw("failed to base64 decode message...", zap.Error(err)) el.Metrics.EventProcessingFailed(el.GetEventSourceName(), el.GetEventName())