@@ -450,7 +450,7 @@ private final class CommitRunnable implements Runnable {
450
450
@ Override
451
451
public void run () {
452
452
XGoogSpannerRequestId reqId =
453
- session .getRequestIdCreator ().nextRequestId (1 /*TODO: channelId */ , 1 );
453
+ session .getRequestIdCreator ().nextRequestId (session . getChannel () , 1 );
454
454
try {
455
455
prev .get ();
456
456
if (transactionId == null && transactionIdFuture == null ) {
@@ -930,7 +930,7 @@ private ResultSet internalExecuteUpdate(
930
930
getExecuteSqlRequestBuilder (
931
931
statement , queryMode , options , /* withTransactionSelector= */ true );
932
932
XGoogSpannerRequestId reqId =
933
- session .getRequestIdCreator ().nextRequestId (1 /*TODO: channelId */ , 1 );
933
+ session .getRequestIdCreator ().nextRequestId (session . getChannel () , 1 );
934
934
try {
935
935
com .google .spanner .v1 .ResultSet resultSet =
936
936
rpc .executeQuery (
@@ -1066,7 +1066,7 @@ public long[] batchUpdate(Iterable<Statement> statements, UpdateOption... update
1066
1066
final ExecuteBatchDmlRequest .Builder builder =
1067
1067
getExecuteBatchDmlRequestBuilder (statements , options );
1068
1068
XGoogSpannerRequestId reqId =
1069
- session .getRequestIdCreator ().nextRequestId (1 /*TODO: channelId */ , 1 );
1069
+ session .getRequestIdCreator ().nextRequestId (session . getChannel () , 1 );
1070
1070
try {
1071
1071
com .google .spanner .v1 .ExecuteBatchDmlResponse response =
1072
1072
rpc .executeBatchDml (builder .build (), reqId .withOptions (getTransactionChannelHint ()));
@@ -1128,7 +1128,7 @@ public ApiFuture<long[]> batchUpdateAsync(
1128
1128
getExecuteBatchDmlRequestBuilder (statements , options );
1129
1129
ApiFuture <com .google .spanner .v1 .ExecuteBatchDmlResponse > response ;
1130
1130
XGoogSpannerRequestId reqId =
1131
- session .getRequestIdCreator ().nextRequestId (1 /*TODO: channelId */ , 1 );
1131
+ session .getRequestIdCreator ().nextRequestId (session . getChannel () , 1 );
1132
1132
try {
1133
1133
// Register the update as an async operation that must finish before the transaction may
1134
1134
// commit.
0 commit comments