Merge pull request #267579 from spelluru/sbusjava0228

No need of CountDownLatch

Author: prmerger-automator[bot]

articles/service-bus-messaging/service-bus-java-how-to-use-queues.md

@@ -1,7 +1,7 @@
 ---
 title: Get started with Azure Service Bus queues (Java)
 description: This tutorial shows you how to send messages to and receive messages from Azure Service Bus queues using the Java programming language.
-ms.date: 04/12/2023
+ms.date: 02/28/2024
 ms.topic: quickstart
 ms.devlang: java
 ms.custom: passwordless-java, devx-track-extended-java
@@ -34,7 +34,7 @@ In this quickstart, you create a Java app to send messages to and receive messag
 
 
 ## Send messages to a queue
-In this section, you create a Java console project, and add code to send messages to the queue that you created earlier.
+In this section, you'll create a Java console project, and add code to send messages to the queue that you created earlier.
 
 ### Create a Java console project
 Create a Java project using Eclipse or a tool of your choice.
@@ -86,7 +86,6 @@ Update the `pom.xml` file to add a dependency to the Azure Service Bus package.
     import com.azure.messaging.servicebus.*;
     import com.azure.identity.*;
 
-    import java.util.concurrent.CountDownLatch;
     import java.util.concurrent.TimeUnit;
     import java.util.Arrays;
     import java.util.List;
@@ -97,7 +96,6 @@ Update the `pom.xml` file to add a dependency to the Azure Service Bus package.
     ```java
     import com.azure.messaging.servicebus.*;
 
-    import java.util.concurrent.CountDownLatch;
     import java.util.concurrent.TimeUnit;
     import java.util.Arrays;
     import java.util.List;
@@ -310,8 +308,6 @@ In this section, you add code to retrieve messages from the queue.
     // handles received messages
     static void receiveMessages() throws InterruptedException
     {
-        CountDownLatch countdownLatch = new CountDownLatch(1);
-
         DefaultAzureCredential credential = new DefaultAzureCredentialBuilder()
                 .build();
 
@@ -320,8 +316,8 @@ In this section, you add code to retrieve messages from the queue.
                 .credential(credential)
                 .processor()
                 .queueName(queueName)
-                .processMessage(QueueTest::processMessage)
-                .processError(context -> processError(context, countdownLatch))
+                .processMessage(context -> processMessage(context))
+                .processError(context -> processError(context))
                 .buildProcessorClient();
 
         System.out.println("Starting the processor");
@@ -342,15 +338,13 @@ In this section, you add code to retrieve messages from the queue.
     // handles received messages
     static void receiveMessages() throws InterruptedException
     {
-        CountDownLatch countdownLatch = new CountDownLatch(1);
-
         // Create an instance of the processor through the ServiceBusClientBuilder
         ServiceBusProcessorClient processorClient = new ServiceBusClientBuilder()
             .connectionString(connectionString)
             .processor()
             .queueName(queueName)
             .processMessage(QueueTest::processMessage)
-            .processError(context -> processError(context, countdownLatch))
+            .processError(context -> processError(context))
             .buildProcessorClient();
 
         System.out.println("Starting the processor");
@@ -374,7 +368,7 @@ In this section, you add code to retrieve messages from the queue.
 3. Add the `processError` method to handle error messages.
 
     ```java
-    private static void processError(ServiceBusErrorContext context, CountDownLatch countdownLatch) {
+    private static void processError(ServiceBusErrorContext context) {
         System.out.printf("Error when receiving messages from namespace: '%s'. Entity: '%s'%n",
             context.getFullyQualifiedNamespace(), context.getEntityPath());
 
@@ -391,8 +385,6 @@ In this section, you add code to retrieve messages from the queue.
             || reason == ServiceBusFailureReason.UNAUTHORIZED) {
             System.out.printf("An unrecoverable error occurred. Stopping processing with reason %s: %s%n",
                 reason, exception.getMessage());
-
-            countdownLatch.countDown();
         } else if (reason == ServiceBusFailureReason.MESSAGE_LOCK_LOST) {
             System.out.printf("Message lock lost for message: %s%n", context.getException());
         } else if (reason == ServiceBusFailureReason.SERVICE_BUSY) {
@@ -423,7 +415,7 @@ In this section, you add code to retrieve messages from the queue.
 ### [Passwordless (Recommended)](#tab/passwordless)
 
 1. If you're using Eclipse, right-click the project, select **Export**, expand **Java**, select **Runnable JAR file**, and follow the steps to create a runnable JAR file.
-1. If you are signed into the machine using a user account that's different from the user account added to the **Azure Service Bus Data Owner** role, follow these steps. Otherwise, skip this step and move on to run the Jar file in the next step.
+1. If you're signed into the machine using a user account that's different from the user account added to the **Azure Service Bus Data Owner** role, follow these steps. Otherwise, skip this step and move on to run the Jar file in the next step.
 
     1. [Install Azure CLI](/cli/azure/install-azure-cli-windows) on your machine.
     1. Run the following CLI command to sign in to Azure. Use the same user account that you added to the **Azure Service Bus Data Owner** role.
@@ -464,7 +456,7 @@ Stopping and closing the processor
 ```
 ---
 
-On the **Overview** page for the Service Bus namespace in the Azure portal, you can see **incoming** and **outgoing** message count. You may need to wait for a minute or so and then refresh the page to see the latest values.
+On the **Overview** page for the Service Bus namespace in the Azure portal, you can see **incoming** and **outgoing** message count. Wait for a minute or so and then refresh the page to see the latest values.
 
 :::image type="content" source="./media/service-bus-java-how-to-use-queues/overview-incoming-outgoing-messages.png" alt-text="Incoming and outgoing message count" lightbox="./media/service-bus-java-how-to-use-queues/overview-incoming-outgoing-messages.png":::
 

articles/service-bus-messaging/service-bus-java-how-to-use-topics-subscriptions.md

@@ -1,7 +1,7 @@
 ---
 title: Get started with Azure Service Bus topics (Java)
 description: This tutorial shows you how to send messages to Azure Service Bus topics and receive messages from topics' subscriptions using the Java programming language.
-ms.date: 04/12/2023
+ms.date: 02/28/2024
 ms.topic: quickstart
 ms.devlang: java
 ms.custom: mode-api, devx-track-extended-java
@@ -86,7 +86,6 @@ Update the `pom.xml` file to add a dependency to the Azure Service Bus package.
     import com.azure.messaging.servicebus.*;
     import com.azure.identity.*;
 
-    import java.util.concurrent.CountDownLatch;
     import java.util.concurrent.TimeUnit;
     import java.util.Arrays;
     import java.util.List;
@@ -97,7 +96,6 @@ Update the `pom.xml` file to add a dependency to the Azure Service Bus package.
     ```java
     import com.azure.messaging.servicebus.*;
 
-    import java.util.concurrent.CountDownLatch;
     import java.util.concurrent.TimeUnit;
     import java.util.Arrays;
     import java.util.List;
@@ -311,8 +309,6 @@ In this section, you add code to retrieve messages from a subscription to the to
     // handles received messages
     static void receiveMessages() throws InterruptedException
     {
-        CountDownLatch countdownLatch = new CountDownLatch(1);
-
         DefaultAzureCredential credential = new DefaultAzureCredentialBuilder()
                 .build();
 
@@ -323,8 +319,8 @@ In this section, you add code to retrieve messages from a subscription to the to
             .processor()
             .topicName(topicName)
             .subscriptionName(subName)
-            .processMessage(ServiceBusTopicTest::processMessage)
-            .processError(context -> processError(context, countdownLatch))
+            .processMessage(context -> processMessage(context))
+            .processError(context -> processError(context))
             .buildProcessorClient();
 
         System.out.println("Starting the processor");
@@ -345,16 +341,14 @@ In this section, you add code to retrieve messages from a subscription to the to
     // handles received messages
     static void receiveMessages() throws InterruptedException
     {
-        CountDownLatch countdownLatch = new CountDownLatch(1);
-
         // Create an instance of the processor through the ServiceBusClientBuilder
         ServiceBusProcessorClient processorClient = new ServiceBusClientBuilder()
             .connectionString(connectionString)
             .processor()
             .topicName(topicName)
             .subscriptionName(subName)
-            .processMessage(ServiceBusTopicTest::processMessage)
-            .processError(context -> processError(context, countdownLatch))
+            .processMessage(context -> processMessage(context))
+            .processError(context -> processError(context))
             .buildProcessorClient();
 
         System.out.println("Starting the processor");
@@ -378,7 +372,7 @@ In this section, you add code to retrieve messages from a subscription to the to
 3. Add the `processError` method to handle error messages.
 
     ```java
-    private static void processError(ServiceBusErrorContext context, CountDownLatch countdownLatch) {
+    private static void processError(ServiceBusErrorContext context) {
         System.out.printf("Error when receiving messages from namespace: '%s'. Entity: '%s'%n",
             context.getFullyQualifiedNamespace(), context.getEntityPath());
 
@@ -395,8 +389,6 @@ In this section, you add code to retrieve messages from a subscription to the to
             || reason == ServiceBusFailureReason.UNAUTHORIZED) {
             System.out.printf("An unrecoverable error occurred. Stopping processing with reason %s: %s%n",
                 reason, exception.getMessage());
-
-            countdownLatch.countDown();
         } else if (reason == ServiceBusFailureReason.MESSAGE_LOCK_LOST) {
             System.out.printf("Message lock lost for message: %s%n", context.getException());
         } else if (reason == ServiceBusFailureReason.SERVICE_BUSY) {
@@ -428,7 +420,7 @@ Run the program to see the output similar to the following output:
 ### [Passwordless (Recommended)](#tab/passwordless)
 
 1. If you're using Eclipse, right-click the project, select **Export**, expand **Java**, select **Runnable JAR file**, and follow the steps to create a runnable JAR file.
-1. If you are signed into the machine using a user account that's different from the user account added to the **Azure Service Bus Data Owner** role, follow these steps. Otherwise, skip this step and move on to run the Jar file in the next step.
+1. If you're signed into the machine using a user account that's different from the user account added to the **Azure Service Bus Data Owner** role, follow these steps. Otherwise, skip this step and move on to run the Jar file in the next step.
 
     1. [Install Azure CLI](/cli/azure/install-azure-cli-windows) on your machine.
     1. Run the following CLI command to sign in to Azure. Use the same user account that you added to the **Azure Service Bus Data Owner** role.
@@ -466,7 +458,7 @@ Processing message. Session: 7bd3bd3e966a40ebbc9b29b082da14bb, Sequence #: 4. Co
 ```
 ---
 
-On the **Overview** page for the Service Bus namespace in the Azure portal, you can see **incoming** and **outgoing** message count. You may need to wait for a minute or so and then refresh the page to see the latest values.
+On the **Overview** page for the Service Bus namespace in the Azure portal, you can see **incoming** and **outgoing** message count. Wait for a minute or so and then refresh the page to see the latest values.
 
 :::image type="content" source="./media/service-bus-java-how-to-use-queues/overview-incoming-outgoing-messages.png" alt-text="Incoming and outgoing message count" lightbox="./media/service-bus-java-how-to-use-queues/overview-incoming-outgoing-messages.png":::