File tree Expand file tree Collapse file tree 2 files changed +10
-12
lines changed
main/java/com/google/cloud/spanner
test/java/com/google/cloud/spanner Expand file tree Collapse file tree 2 files changed +10
-12
lines changed Original file line number Diff line number Diff line change @@ -513,9 +513,8 @@ ApiFuture<Transaction> beginTransactionAsync(
513513 requestBuilder .setMutationKey (mutation );
514514 }
515515 if (sessionReference .getIsMultiplexed () && !Strings .isNullOrEmpty (transactionOptions .tag ())) {
516- requestBuilder .setRequestOptions (RequestOptions .newBuilder ()
517- .setTransactionTag (transactionOptions .tag ())
518- .build ());
516+ requestBuilder .setRequestOptions (
517+ RequestOptions .newBuilder ().setTransactionTag (transactionOptions .tag ()).build ());
519518 }
520519 final BeginTransactionRequest request = requestBuilder .build ();
521520 final ApiFuture <Transaction > requestFuture ;
Original file line number Diff line number Diff line change @@ -1903,23 +1903,22 @@ public void testBlindWriteWithTransactionTag() {
19031903 DatabaseClient client =
19041904 spanner .getDatabaseClient (DatabaseId .of (TEST_PROJECT , TEST_INSTANCE , TEST_DATABASE ));
19051905 String transactionTag = "app=spanner,env=test,action=txn" ;
1906- TransactionRunner runner =
1907- client .readWriteTransaction (Options .tag (transactionTag ));
1906+ TransactionRunner runner = client .readWriteTransaction (Options .tag (transactionTag ));
19081907 runner .run (
19091908 transaction -> {
1910- transaction .buffer (Mutation .newInsertBuilder ("abc" )
1911- .set ("id" )
1912- .to (1L )
1913- .build ());
1909+ transaction .buffer (Mutation .newInsertBuilder ("abc" ).set ("id" ).to (1L ).build ());
19141910 return null ;
19151911 });
19161912
1917- List <BeginTransactionRequest > beginTransactionRequests = mockSpanner .getRequestsOfType (BeginTransactionRequest .class );
1913+ List <BeginTransactionRequest > beginTransactionRequests =
1914+ mockSpanner .getRequestsOfType (BeginTransactionRequest .class );
19181915 assertThat (beginTransactionRequests ).hasSize (1 );
1919- assertThat (beginTransactionRequests .get (0 ).getRequestOptions ().getTransactionTag ()).isEqualTo (transactionTag );
1916+ assertThat (beginTransactionRequests .get (0 ).getRequestOptions ().getTransactionTag ())
1917+ .isEqualTo (transactionTag );
19201918 List <CommitRequest > commitRequests = mockSpanner .getRequestsOfType (CommitRequest .class );
19211919 assertThat (commitRequests ).hasSize (1 );
1922- assertThat (commitRequests .get (0 ).getRequestOptions ().getTransactionTag ()).isEqualTo (transactionTag );
1920+ assertThat (commitRequests .get (0 ).getRequestOptions ().getTransactionTag ())
1921+ .isEqualTo (transactionTag );
19231922 }
19241923
19251924 @ Test
You can’t perform that action at this time.
0 commit comments