diff --git a/sdk/servicebus/azure-messaging-servicebus/src/samples/README.md b/sdk/servicebus/azure-messaging-servicebus/src/samples/README.md index 6c3493121f5f..5607126b49c1 100644 --- a/sdk/servicebus/azure-messaging-servicebus/src/samples/README.md +++ b/sdk/servicebus/azure-messaging-servicebus/src/samples/README.md @@ -88,6 +88,7 @@ Guidelines](https://github.com/Azure/azure-sdk-for-java/blob/main/CONTRIBUTING.m [SendMessageWithAzureIdentityAsyncSample]: https://github.com/Azure/azure-sdk-for-java/blob/main/sdk/servicebus/azure-messaging-servicebus/src/samples/java/com/azure/messaging/servicebus/SendMessageWithAzureIdentityAsyncSample.java [SendScheduledMessageAndCancelAsyncSample]: https://github.com/Azure/azure-sdk-for-java/blob/main/sdk/servicebus/azure-messaging-servicebus/src/samples/java/com/azure/messaging/servicebus/SendScheduledMessageAndCancelAsyncSample.java [ServiceBusProcessorSample]: https://github.com/Azure/azure-sdk-for-java/blob/main/sdk/servicebus/azure-messaging-servicebus/src/samples/java/com/azure/messaging/servicebus/ServiceBusProcessorSample.java +[ServiceBusReceiverAsyncClientRetrySample]: https://github.com/Azure/azure-sdk-for-java/blob/main/sdk/servicebus/azure-messaging-servicebus/src/samples/java/com/azure/messaging/servicebus/ServiceBusReceiverAsyncClientRetrySample.java [ServiceBusSessionProcessorSample]: https://github.com/Azure/azure-sdk-for-java/blob/main/sdk/servicebus/azure-messaging-servicebus/src/samples/java/com/azure/messaging/servicebus/ServiceBusSessionProcessorSample.java [AdministrationClientUpdateQueueSample]: https://github.com/Azure/azure-sdk-for-java/blob/main/sdk/servicebus/azure-messaging-servicebus/src/samples/java/com/azure/messaging/servicebus/AdministrationClientUpdateQueueSample.java [ReceiveMessageAsyncUsingSasSample]: https://github.com/Azure/azure-sdk-for-java/blob/main/sdk/servicebus/azure-messaging-servicebus/src/samples/java/com/azure/messaging/servicebus/ReceiveMessageUsingSasSample.java diff --git a/sdk/servicebus/azure-messaging-servicebus/src/samples/java/com/azure/messaging/servicebus/ServiceBusReceiverAsyncClientRetrySample.java b/sdk/servicebus/azure-messaging-servicebus/src/samples/java/com/azure/messaging/servicebus/ServiceBusReceiverAsyncClientRetrySample.java index ed624ceb07c9..424403ad575c 100644 --- a/sdk/servicebus/azure-messaging-servicebus/src/samples/java/com/azure/messaging/servicebus/ServiceBusReceiverAsyncClientRetrySample.java +++ b/sdk/servicebus/azure-messaging-servicebus/src/samples/java/com/azure/messaging/servicebus/ServiceBusReceiverAsyncClientRetrySample.java @@ -21,12 +21,12 @@ import java.util.function.Function; /** - * The sample demonstrates how handle terminal error from {@link ServiceBusReceiverAsyncClient} (aka LowLevelClient) - * and recreate the LowLevelClient to continue receive. - * + * The sample demonstrates how handle terminal error from {@link ServiceBusReceiverAsyncClient#receiveMessages()} + * and recreate the client to continue receiving messages. + * *
- * The {@link ServiceBusReceiverAsyncClient} emits a terminal error (hence no longer emit messages) in - * the following cases - + * The {@link ServiceBusReceiverAsyncClient#receiveMessages()} emits a terminal error (hence no longer emit messages) + * in the following cases - * *
* When these cases happen, the usual pattern is to log the terminal error for auditing and create a new client - * to receive messages. + * to continue receiving messages. */ public class ServiceBusReceiverAsyncClientRetrySample { private static final ClientLogger LOGGER = new ClientLogger(ServiceBusReceiverAsyncClientRetrySample.class); @@ -48,8 +48,8 @@ public class ServiceBusReceiverAsyncClientRetrySample { String queueName = System.getenv("AZURE_SERVICEBUS_SAMPLE_QUEUE_NAME"); /** - * Main method to show how to handle terminal error from ServiceBusReceiverAsyncClient to - * continue receive from Service Bus queue. + * Main method of the sample showing how to handle terminal error from + * {@link ServiceBusReceiverAsyncClient#receiveMessages()} and recreate the client to continue receiving messages. * * @param args Unused arguments to the program. * @@ -61,8 +61,8 @@ public static void main(String[] args) throws InterruptedException { } /** - * Run method to invoke this demo on how to handle terminal error from ServiceBusReceiverAsyncClient to - * continue receive from Service Bus queue. + * Run method to invoke this demo on how to handle terminal error from + * {@link ServiceBusReceiverAsyncClient#receiveMessages()} and recreate the client to continue receiving messages. */ @Test public void run() throws InterruptedException {