Skip to content
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 0 additions & 4 deletions sdk/servicebus/azure-messaging-servicebus/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -265,7 +265,6 @@ ServiceBusProcessorClient processorClient = new ServiceBusClientBuilder()
.disableAutoComplete() // Make sure to explicitly opt in to manual settlement (e.g. complete, abandon).
.processMessage(processMessage)
.processError(processError)
.disableAutoComplete()
.buildProcessorClient();

// Starts the processor in the background. Control returns immediately.
Expand Down Expand Up @@ -302,15 +301,13 @@ TokenCredential tokenCredential = new DefaultAzureCredentialBuilder().build();

// Create the processor client via the builder and its sub-builder
// 'fullyQualifiedNamespace' will look similar to "{your-namespace}.servicebus.windows.net"
// 'disableAutoComplete()' will opt in to manual settlement (e.g. complete, abandon).
ServiceBusProcessorClient processorClient = new ServiceBusClientBuilder()
.credential(fullyQualifiedNamespace, tokenCredential)
.processor()
.queueName(queueName)
.receiveMode(ServiceBusReceiveMode.RECEIVE_AND_DELETE)
.processMessage(processMessage)
.processError(processError)
.disableAutoComplete()
.buildProcessorClient();

// Starts the processor in the background. Control returns immediately.
Expand Down Expand Up @@ -385,7 +382,6 @@ created the same way as shown below. Learn more about dead-letter queue [here][d
TokenCredential credential = new DefaultAzureCredentialBuilder().build();

// 'fullyQualifiedNamespace' will look similar to "{your-namespace}.servicebus.windows.net"
// 'disableAutoComplete' indicates that users will explicitly settle their message.
ServiceBusReceiverClient receiver = new ServiceBusClientBuilder()
.credential(fullyQualifiedNamespace, credential)
.receiver() // Use this for session or non-session enabled queue or topic/subscriptions
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -254,7 +254,6 @@
* .disableAutoComplete() // Make sure to explicitly opt in to manual settlement (e.g. complete, abandon).
* .processMessage(processMessage)
* .processError(processError)
* .disableAutoComplete()
* .buildProcessorClient();
*
* // Starts the processor in the background. Control returns immediately.
Expand Down Expand Up @@ -2333,7 +2332,6 @@ private ServiceBusSessionReceiverAsyncClient buildAsyncClient(boolean isForSyncM
* .disableAutoComplete() // Make sure to explicitly opt in to manual settlement (e.g. complete, abandon).
* .processMessage(processMessage)
* .processError(processError)
* .disableAutoComplete()
* .buildProcessorClient();
*
* // Starts the processor in the background. Control returns immediately.
Expand Down Expand Up @@ -2370,15 +2368,13 @@ private ServiceBusSessionReceiverAsyncClient buildAsyncClient(boolean isForSyncM
*
* // Create the processor client via the builder and its sub-builder
* // 'fullyQualifiedNamespace' will look similar to "{your-namespace}.servicebus.windows.net"
* // 'disableAutoComplete()' will opt in to manual settlement (e.g. complete, abandon).
* ServiceBusProcessorClient processorClient = new ServiceBusClientBuilder()
* .credential(fullyQualifiedNamespace, tokenCredential)
* .processor()
* .queueName(queueName)
* .receiveMode(ServiceBusReceiveMode.RECEIVE_AND_DELETE)
* .processMessage(processMessage)
* .processError(processError)
* .disableAutoComplete()
* .buildProcessorClient();
*
* // Starts the processor in the background. Control returns immediately.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -79,7 +79,6 @@
* .disableAutoComplete() // Make sure to explicitly opt in to manual settlement (e.g. complete, abandon).
* .processMessage(processMessage)
* .processError(processError)
* .disableAutoComplete()
* .buildProcessorClient();
*
* // Starts the processor in the background. Control returns immediately.
Expand Down Expand Up @@ -116,15 +115,13 @@
*
* // Create the processor client via the builder and its sub-builder
* // 'fullyQualifiedNamespace' will look similar to "{your-namespace}.servicebus.windows.net"
* // 'disableAutoComplete()' will opt in to manual settlement (e.g. complete, abandon).
* ServiceBusProcessorClient processorClient = new ServiceBusClientBuilder()
* .credential(fullyQualifiedNamespace, tokenCredential)
* .processor()
* .queueName(queueName)
* .receiveMode(ServiceBusReceiveMode.RECEIVE_AND_DELETE)
* .processMessage(processMessage)
* .processError(processError)
* .disableAutoComplete()
* .buildProcessorClient();
*
* // Starts the processor in the background. Control returns immediately.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -184,7 +184,6 @@
* .disableAutoComplete() // Make sure to explicitly opt in to manual settlement (e.g. complete, abandon).
* .processMessage(processMessage)
* .processError(processError)
* .disableAutoComplete()
* .buildProcessorClient();
*
* // Starts the processor in the background. Control returns immediately.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -84,7 +84,6 @@ public void createServiceBusProcessorClientInPeekLockMode() {
.disableAutoComplete() // Make sure to explicitly opt in to manual settlement (e.g. complete, abandon).
.processMessage(processMessage)
.processError(processError)
.disableAutoComplete()
.buildProcessorClient();

// Starts the processor in the background. Control returns immediately.
Expand Down Expand Up @@ -125,15 +124,13 @@ public void createServiceBusProcessorClientInReceiveAndDeleteMode() {

// Create the processor client via the builder and its sub-builder
// 'fullyQualifiedNamespace' will look similar to "{your-namespace}.servicebus.windows.net"
// 'disableAutoComplete()' will opt in to manual settlement (e.g. complete, abandon).
ServiceBusProcessorClient processorClient = new ServiceBusClientBuilder()
.credential(fullyQualifiedNamespace, tokenCredential)
.processor()
.queueName(queueName)
.receiveMode(ServiceBusReceiveMode.RECEIVE_AND_DELETE)
.processMessage(processMessage)
.processError(processError)
.disableAutoComplete()
.buildProcessorClient();

// Starts the processor in the background. Control returns immediately.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -114,7 +114,6 @@ public void instantiateDeadLetterQueue() {
TokenCredential credential = new DefaultAzureCredentialBuilder().build();

// 'fullyQualifiedNamespace' will look similar to "{your-namespace}.servicebus.windows.net"
// 'disableAutoComplete' indicates that users will explicitly settle their message.
ServiceBusReceiverClient receiver = new ServiceBusClientBuilder()
.credential(fullyQualifiedNamespace, credential)
.receiver() // Use this for session or non-session enabled queue or topic/subscriptions
Expand Down