From e5a8715e25ed3d8871d0515fffb78d662e9d7c71 Mon Sep 17 00:00:00 2001 From: Bill Johnson <436997+dubrie@users.noreply.github.com> Date: Thu, 7 May 2020 16:23:41 -0700 Subject: [PATCH] Update MessageAndSessionPump.java Fixing typo is MessageRenewLockLoop --- .../microsoft/azure/servicebus/MessageAndSessionPump.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/azure-servicebus/src/main/java/com/microsoft/azure/servicebus/MessageAndSessionPump.java b/azure-servicebus/src/main/java/com/microsoft/azure/servicebus/MessageAndSessionPump.java index 49b32296..abf9b785 100644 --- a/azure-servicebus/src/main/java/com/microsoft/azure/servicebus/MessageAndSessionPump.java +++ b/azure-servicebus/src/main/java/com/microsoft/azure/servicebus/MessageAndSessionPump.java @@ -164,10 +164,10 @@ private void receiveAndPumpMessage() { } else { TRACE_LOGGER.trace("Message with sequence number '{}' received from entity '{}'.", message.getSequenceNumber(), this.entityPath); // Start renew lock loop - final MessgeRenewLockLoop renewLockLoop; + final MessageRenewLockLoop renewLockLoop; if (this.innerReceiver.getReceiveMode() == ReceiveMode.PEEKLOCK) { Instant stopRenewMessageLockAt = Instant.now().plus(this.messageHandlerOptions.getMaxAutoRenewDuration()); - renewLockLoop = new MessgeRenewLockLoop(this.innerReceiver, this, message, stopRenewMessageLockAt); + renewLockLoop = new MessageRenewLockLoop(this.innerReceiver, this, message, stopRenewMessageLockAt); renewLockLoop.startLoop(); TRACE_LOGGER.trace("Started loop to renew lock on message with sequence number '{}' until '{}'", message.getSequenceNumber(), stopRenewMessageLockAt); } else { @@ -554,7 +554,7 @@ protected static Duration getNextRenewInterval(Instant lockedUntilUtc, String id } } - private static class MessgeRenewLockLoop extends RenewLockLoop { + private static class MessageRenewLockLoop extends RenewLockLoop { private IMessageReceiver innerReceiver; private MessageAndSessionPump messageAndSessionPump; private IMessage message; @@ -562,7 +562,7 @@ private static class MessgeRenewLockLoop extends RenewLockLoop { private String messageIdentifier; ScheduledFuture timerFuture; - MessgeRenewLockLoop(IMessageReceiver innerReceiver, MessageAndSessionPump messageAndSessionPump, IMessage message, Instant stopRenewalAt) { + MessageRenewLockLoop(IMessageReceiver innerReceiver, MessageAndSessionPump messageAndSessionPump, IMessage message, Instant stopRenewalAt) { super(); this.innerReceiver = innerReceiver; this.messageAndSessionPump = messageAndSessionPump;