Skip to content

Commit f285a29

Browse files
chore: apply fmt-maven-plugin
1 parent aa09bfe commit f285a29

2 files changed

Lines changed: 6 additions & 9 deletions

File tree

  • java-bigtable/google-cloud-bigtable/src

java-bigtable/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/internal/session/SessionImpl.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -814,7 +814,8 @@ private void notifyTerminalClose(
814814
} catch (Throwable t) {
815815
logger.log(
816816
Level.WARNING,
817-
String.format("Session error: %s Unhandled exception in tracer.onClose", info.getLogName()),
817+
String.format(
818+
"Session error: %s Unhandled exception in tracer.onClose", info.getLogName()),
818819
t);
819820
}
820821
if (sessionListener != null) {

java-bigtable/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/data/v2/internal/session/SessionImplTest.java

Lines changed: 4 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -676,8 +676,7 @@ void testHeartbeatScheduledOnlyDuringVRpc() throws Exception {
676676

677677
@Test
678678
void abortFiresWhenListenerOnReadyThrows() throws Exception {
679-
SessionImpl session =
680-
new SessionImpl(metrics, poolInfo, 0, sessionFactory.createNew(), timer);
679+
SessionImpl session = new SessionImpl(metrics, poolInfo, 0, sessionFactory.createNew(), timer);
681680

682681
java.util.concurrent.CountDownLatch onCloseLatch = new java.util.concurrent.CountDownLatch(1);
683682
java.util.concurrent.atomic.AtomicReference<Status> capturedStatus =
@@ -718,8 +717,7 @@ public void onClose(Session.SessionState prevState, Status status, Metadata trai
718717

719718
@Test
720719
void abortDoesNotHangWhenListenerOnCloseThrows() throws Exception {
721-
SessionImpl session =
722-
new SessionImpl(metrics, poolInfo, 0, sessionFactory.createNew(), timer);
720+
SessionImpl session = new SessionImpl(metrics, poolInfo, 0, sessionFactory.createNew(), timer);
723721

724722
java.util.concurrent.CountDownLatch onReadyLatch = new java.util.concurrent.CountDownLatch(1);
725723
java.util.concurrent.CountDownLatch onCloseLatch = new java.util.concurrent.CountDownLatch(1);
@@ -772,11 +770,9 @@ public void onClose(Session.SessionState prevState, Status status, Metadata trai
772770

773771
@Test
774772
void abortDoesNotInfiniteLoopWhenRecoveryListenerAlsoThrows() throws Exception {
775-
SessionImpl session =
776-
new SessionImpl(metrics, poolInfo, 0, sessionFactory.createNew(), timer);
773+
SessionImpl session = new SessionImpl(metrics, poolInfo, 0, sessionFactory.createNew(), timer);
777774

778-
java.util.concurrent.CountDownLatch onCloseInvoked =
779-
new java.util.concurrent.CountDownLatch(1);
775+
java.util.concurrent.CountDownLatch onCloseInvoked = new java.util.concurrent.CountDownLatch(1);
780776

781777
Session.Listener doublyThrowingListener =
782778
new Session.Listener() {

0 commit comments

Comments
 (0)