fix(AzureQueueStorage): update base64 encoding (#3104)

argoproj · Apr 19, 2024 · 82302f3 · 82302f3
1 parent af13bf5
commit 82302f3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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())