Skip to content

Commit 021e7f5

Browse files
committed
Use withNewServerDeprioritization.
1 parent d1868a3 commit 021e7f5

2 files changed

Lines changed: 3 additions & 3 deletions

File tree

driver-core/src/main/com/mongodb/internal/connection/OperationContext.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -116,8 +116,8 @@ public OperationContext withOperationName(final String operationName) {
116116

117117
// TODO-JAVA-6058: This method enables overriding the ServerDeprioritization state.
118118
// It is a temporary solution to handle cases where deprioritization state persists across operations.
119-
public OperationContext withServerDeprioritization(final ServerDeprioritization serverDeprioritization) {
120-
return new OperationContext(id, requestContext, sessionContext, timeoutContext, serverDeprioritization, tracingManager, serverApi,
119+
public OperationContext withNewServerDeprioritization() {
120+
return new OperationContext(id, requestContext, sessionContext, timeoutContext, new ServerDeprioritization(), tracingManager, serverApi,
121121
operationName, tracingSpan);
122122
}
123123

driver-core/src/main/com/mongodb/internal/operation/ChangeStreamBatchCursor.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -87,7 +87,7 @@ final class ChangeStreamBatchCursor<T> implements AggregateResponseBatchCursor<T
8787
this.binding = binding.retain();
8888
this.initialOperationContext = operationContext
8989
.withOverride(TimeoutContext::withMaxTimeAsMaxAwaitTimeOverride)
90-
.withServerDeprioritization(new OperationContext.ServerDeprioritization());
90+
.withNewServerDeprioritization();
9191
this.wrapped = wrapped;
9292
this.resumeToken = resumeToken;
9393
this.maxWireVersion = maxWireVersion;

0 commit comments

Comments
 (0)