Skip to content

Commit 97ba7e1

Browse files
authored
Fix an session ReceiverOption value error. (Azure#17208)
1 parent 8cf8a4b commit 97ba7e1

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

sdk/servicebus/azure-messaging-servicebus/src/main/java/com/azure/messaging/servicebus/ServiceBusSessionReceiverAsyncClient.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,7 @@ public Mono<ServiceBusReceiverAsyncClient> acceptNextSession() {
7878
.map(sessionId -> {
7979
final ReceiverOptions newReceiverOptions = new ReceiverOptions(receiverOptions.getReceiveMode(),
8080
receiverOptions.getPrefetchCount(), receiverOptions.getMaxLockRenewDuration(),
81-
receiverOptions.isAutoLockRenewEnabled(), sessionId, null);
81+
receiverOptions.isEnableAutoComplete(), sessionId, null);
8282
final ServiceBusSessionManager sessionSpecificManager = new ServiceBusSessionManager(entityPath,
8383
entityType, connectionProcessor, tracerProvider, messageSerializer, newReceiverOptions,
8484
receiveLink);
@@ -112,7 +112,7 @@ public Mono<ServiceBusReceiverAsyncClient> acceptSession(String sessionId) {
112112
}
113113
final ReceiverOptions newReceiverOptions = new ReceiverOptions(receiverOptions.getReceiveMode(),
114114
receiverOptions.getPrefetchCount(), receiverOptions.getMaxLockRenewDuration(),
115-
receiverOptions.isAutoLockRenewEnabled(), sessionId, null);
115+
receiverOptions.isEnableAutoComplete(), sessionId, null);
116116
final ServiceBusSessionManager sessionSpecificManager = new ServiceBusSessionManager(entityPath, entityType,
117117
connectionProcessor, tracerProvider, messageSerializer, newReceiverOptions);
118118

0 commit comments

Comments
 (0)