Add sample to consistent with other languages. (Azure#30805)

* sample consistency

* add more sample

Author: ZejiaJiang

sdk/servicebus/azure-messaging-servicebus/src/samples/README.md

@@ -58,6 +58,12 @@ connection string value can be obtained by:
 ### Generate Shared Access Signature
 - [Generate SAS and receive message][ReceiveMessageAsyncUsingSasSample]
 
+### Advanced Configuration
+- [Advanced configuration sample set][AdvancedConfigurationSample]
+
+### README samples
+- [Readme_sample][ReadmeSample]
+
 ## Troubleshooting
 See [Troubleshooting][sdk_readme_troubleshooting].
 
@@ -94,5 +100,7 @@ Guidelines](https://github.com/Azure/azure-sdk-for-java/blob/main/CONTRIBUTING.m
 [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
+[AdvancedConfigurationSample]: https://github.com/Azure/azure-sdk-for-java/blob/main/sdk/servicebus/azure-messaging-servicebus/src/samples/java/com/azure/messaging/servicebus/AdvancedConfigurationSample.java
+[ReadmeSample]: https://github.com/Azure/azure-sdk-for-java/blob/main/sdk/servicebus/azure-messaging-servicebus/src/samples/java/com/azure/messaging/servicebus/ReadmeSamples.java
 
 ![Impressions](https://azure-sdk-impressions.azurewebsites.net/api/impressions/azure-sdk-for-java%2Fsdk%2Fservicebus%2Fazure-messaging-servicebus%2Fsrc%2Fsamples%2FREADME.png)

sdk/servicebus/azure-messaging-servicebus/src/samples/java/com/azure/messaging/servicebus/AdvancedConfigurationSample.java

@@ -0,0 +1,43 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+
+package com.azure.messaging.servicebus;
+
+import com.azure.core.amqp.AmqpRetryOptions;
+
+import java.time.Duration;
+
+/**
+ * Class containing code snippets that set advanced configurations.
+ */
+public class AdvancedConfigurationSample {
+
+    /**
+     * Create an asynchronous receiver that use customized retry options.
+     */
+    public void createAsyncServiceBusReceiver() {
+        AmqpRetryOptions retryOptions = new AmqpRetryOptions();
+        retryOptions.setTryTimeout(Duration.ofSeconds(60));
+        retryOptions.setMaxRetries(3);
+        retryOptions.setDelay(Duration.ofMillis(800));
+
+        ServiceBusReceiverAsyncClient receiver = new ServiceBusClientBuilder()
+            .connectionString("<< CONNECTION STRING FOR THE SERVICE BUS NAMESPACE >>")
+            .retryOptions(retryOptions)
+            .receiver()
+            .queueName("<< QUEUE NAME >>")
+            .buildAsyncClient();
+    }
+
+    /**
+     * Create an asynchronous receiver that prefetch 100 messages.
+     */
+    public void createAsyncServiceBusReceiverWithPrefetch() {
+        ServiceBusReceiverAsyncClient receiver = new ServiceBusClientBuilder()
+            .connectionString("<< CONNECTION STRING FOR THE SERVICE BUS NAMESPACE >>")
+            .receiver()
+            .queueName("<< QUEUE NAME >>")
+            .prefetchCount(100)
+            .buildAsyncClient();
+    }
+}

sdk/servicebus/azure-messaging-servicebus/src/samples/java/com/azure/messaging/servicebus/ReadmeSamples.java

@@ -3,6 +3,7 @@
 
 package com.azure.messaging.servicebus;
 
+import com.azure.core.credential.AzureNamedKeyCredential;
 import com.azure.core.credential.TokenCredential;
 import com.azure.core.util.IterableStream;
 import com.azure.identity.DefaultAzureCredentialBuilder;
@@ -62,6 +63,21 @@ public void createAsynchronousServiceBusReceiverWithAzureIdentity() {
         // END: readme-sample-createAsynchronousServiceBusReceiverWithAzureIdentity
     }
 
+    /**
+     * Code sample for creating an asynchronous Service Bus receiver using {@link AzureNamedKeyCredential}.
+     */
+    public void createAsynchronousServiceBusReceiverWithAzureNamedKeyCredential() {
+        // BEGIN: readme-sample-createAsynchronousServiceBusReceiverWithAzureNamedKeyCredential
+        AzureNamedKeyCredential azureNamedKeyCredential =
+            new AzureNamedKeyCredential("<<azure-service-sas-key-name>>", "<<azure-service-sas-key>>");
+        ServiceBusReceiverAsyncClient receiver = new ServiceBusClientBuilder()
+            .credential(azureNamedKeyCredential)
+            .receiver()
+            .queueName("<<queue-name>>")
+            .buildAsyncClient();
+        // END: readme-sample-createAsynchronousServiceBusReceiverWithAzureNamedKeyCredential
+    }
+
     /**
      * Sends messages to a queue.
      */

sdk/servicebus/azure-messaging-servicebus/src/samples/java/com/azure/messaging/servicebus/ReceiveNamedSessionAsyncSample.java

@@ -10,6 +10,7 @@
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 
+import java.nio.charset.StandardCharsets;
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicBoolean;
@@ -73,7 +74,11 @@ public void run() throws InterruptedException {
         // If the session is successfully accepted, begin receiving messages from it.
         // Flux.usingWhen is used to dispose of the receiver after consuming messages completes.
         Disposable subscription = Flux.usingWhen(receiverMono,
-            receiver -> receiver.receiveMessages(),
+            receiver -> {
+                // Customize session state if needed.
+                receiver.setSessionState("new".getBytes(StandardCharsets.UTF_8));
+                return receiver.receiveMessages();
+            },
             receiver -> Mono.fromRunnable(() -> receiver.close()))
             .subscribe(message -> {
                 // Process message.

sdk/servicebus/azure-messaging-servicebus/src/samples/java/com/azure/messaging/servicebus/ReceiveNamedSessionSample.java

@@ -4,9 +4,11 @@
 package com.azure.messaging.servicebus;
 
 import com.azure.core.util.IterableStream;
+import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.Test;
 import reactor.core.publisher.Mono;
 
+import java.nio.charset.StandardCharsets;
 import java.time.Duration;
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.atomic.AtomicBoolean;
@@ -67,6 +69,14 @@ public void run() {
         // A receiver is returned when a lock on the session is acquired, otherwise, it throws an exception.
         ServiceBusReceiverClient receiver = sessionReceiver.acceptSession("greetings-id");
 
+        // Customize session state if needed.
+        byte[] newState = "new".getBytes(StandardCharsets.UTF_8);
+        receiver.setSessionState(newState);
+
+        // Get session state. The assertion is to ensure the state is correct. User should remove this.
+        byte[] state = receiver.getSessionState("greetings-id");
+        Assertions.assertArrayEquals(state, newState);
+
         try {
             while (isRunning.get()) {
                 IterableStream<ServiceBusReceivedMessage> messages = receiver.receiveMessages(10, Duration.ofSeconds(20));