Skip to content

Commit 99a3ea6

Browse files
fix azsb upgrade code changes
1 parent 09b0e6c commit 99a3ea6

File tree

1 file changed

+1
-5
lines changed

1 file changed

+1
-5
lines changed

adapter/pkg/messaging/azure_listener.go

+1-5
Original file line numberDiff line numberDiff line change
@@ -74,12 +74,8 @@ func startBrokerConsumer(connectionString string, sub Subscription, reconnectInt
7474
continue
7575
}
7676
for _, message := range messages {
77-
body, err := message.Body()
78-
if err != nil {
79-
logger.LoggerMsg.Errorf("Failed to parse the ASB message. Subscription: %s, topic: %s error: %v", subName, topic, err)
80-
}
81-
8277
logger.LoggerMsg.Debugf("Message %s from ASB waits to be processed. Subscription: %s, topic: %s", message.MessageID, subName, topic)
78+
body := message.Body
8379
dataChannel <- body
8480
logger.LoggerMsg.Debugf("Message %s from ASB is complete. Subscription: %s, topic: %s", message.MessageID, subName, topic)
8581

0 commit comments

Comments
 (0)