up

Author: lmolkova

sdk/servicebus/azure-messaging-servicebus/src/main/java/com/azure/messaging/servicebus/FluxAutoComplete.java

@@ -74,7 +74,7 @@ static final class AutoCompleteSubscriber extends BaseSubscriber<ServiceBusMessa
         protected void hookOnSubscribe(Subscription subscription) {
             logger.atInfo()
                 .addKeyValue("subscription", subscription)
-                .log("Subscription received.", subscription);
+                .log("Subscription received. Subscribing downstream.");
             downstream.onSubscribe(this);
         }
 

sdk/servicebus/azure-messaging-servicebus/src/main/java/com/azure/messaging/servicebus/ServiceBusMessageSerializer.java

@@ -418,7 +418,7 @@ private ServiceBusReceivedMessage deserializeMessage(Message amqpMessage) {
 
             } else {
                 LOGGER.atWarning()
-                    .addKeyValue("actualType", body.getClass())
+                    .addKeyValue("actualType", body.getType())
                     .log("Message body is not correct. Not setting body contents.");
 
                 amqpMessageBody = AmqpMessageBody.fromData(EMPTY_BYTE_ARRAY);