Inlined method that no longer serves a useful purpose.
@@ -83,7 +83,7 @@ final class ClientSessionImpl extends BaseClientSessionImpl implements ClientSes
throw new MongoInternalException("Invariant violated. Transaction options read concern can not be null");
}
delegate.getOperationExecutor().execute(new CommitTransactionOperation(transactionOptions.getWriteConcern()),
- getTransactionReadPreferenceOrPrimary(), readConcern, this);
+ ReadPreference.primary(), readConcern, this);
}
} finally {
cleanupTransaction();
@@ -102,7 +102,7 @@ final class ClientSessionImpl extends BaseClientSessionImpl implements ClientSes
throw new MongoInternalException("Invariant violated. Transaction options read concern can not be null");
}
delegate.getOperationExecutor().execute(new AbortTransactionOperation(transactionOptions.getWriteConcern()),
- getTransactionReadPreferenceOrPrimary(), readConcern, this);
+ ReadPreference.primary(), readConcern, this);
}
} catch (Exception e) {
// ignore errors
@@ -133,8 +133,4 @@ final class ClientSessionImpl extends BaseClientSessionImpl implements ClientSes
}
getServerSession().advanceTransactionNumber();
}
-
- private ReadPreference getTransactionReadPreferenceOrPrimary() {
- return ReadPreference.primary();
- }
}
