restart MessageReceiver when requester is null (Azure#21697)

YijunXieMS · web-flow · commit 1530efe73153 · 2021-05-21T00:20:27.000-07:00
diff --git a/sdk/servicebus/azure-messaging-servicebus/src/main/java/com/azure/messaging/servicebus/ServiceBusProcessorClient.java b/sdk/servicebus/azure-messaging-servicebus/src/main/java/com/azure/messaging/servicebus/ServiceBusProcessorClient.java
@@ -337,7 +337,7 @@ private synchronized void restartMessageReceiver(Subscription requester) {
         if (!isRunning()) {
             return;
         }
-        if (!receiverSubscriptions.containsKey(requester)) {
+        if (requester != null && !receiverSubscriptions.containsKey(requester)) {
             return;
         }
         receiverSubscriptions.keySet().forEach(Subscription::cancel);

Original file line number	Diff line number	Diff line change
`@@ -337,7 +337,7 @@ private synchronized void restartMessageReceiver(Subscription requester) {`
`337`	`337`	`if (!isRunning()) {`
`338`	`338`	`return;`
`339`	`339`	`}`
`340`		`- if (!receiverSubscriptions.containsKey(requester)) {`
	`340`	`+ if (requester != null && !receiverSubscriptions.containsKey(requester)) {`
`341`	`341`	`return;`
`342`	`342`	`}`
`343`	`343`	`receiverSubscriptions.keySet().forEach(Subscription::cancel);`