You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by bs...@apache.org on 2019/01/18 00:54:57 UTC
[geode] branch feature/GEODE-6292 updated: spotless
This is an automated email from the ASF dual-hosted git repository.
bschuchardt pushed a commit to branch feature/GEODE-6292
in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/feature/GEODE-6292 by this push:
new 85b30b9 spotless
85b30b9 is described below
commit 85b30b915cd450b5ae3031f06e6abea3f492e1ff
Author: Bruce Schuchardt <bs...@pivotal.io>
AuthorDate: Thu Jan 17 16:54:35 2019 -0800
spotless
---
.../internal/membership/gms/membership/GMSJoinLeaveJUnitTest.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git a/geode-core/src/integrationTest/java/org/apache/geode/distributed/internal/membership/gms/membership/GMSJoinLeaveJUnitTest.java b/geode-core/src/integrationTest/java/org/apache/geode/distributed/internal/membership/gms/membership/GMSJoinLeaveJUnitTest.java
index ad999c7..4630738 100644
--- a/geode-core/src/integrationTest/java/org/apache/geode/distributed/internal/membership/gms/membership/GMSJoinLeaveJUnitTest.java
+++ b/geode-core/src/integrationTest/java/org/apache/geode/distributed/internal/membership/gms/membership/GMSJoinLeaveJUnitTest.java
@@ -14,7 +14,6 @@
*/
package org.apache.geode.distributed.internal.membership.gms.membership;
-import static org.assertj.core.api.Assertions.assertThat;
import static org.apache.geode.test.awaitility.GeodeAwaitility.await;
import static org.assertj.core.api.Assertions.assertThatThrownBy;
import static org.hamcrest.core.IsEqual.equalTo;
@@ -200,12 +199,14 @@ public class GMSJoinLeaveJUnitTest {
gmsJoinLeave.setTcpClientWrapper(tcpClientWrapper);
when(tcpClientWrapper.sendCoordinatorFindRequest(isA(InetSocketAddress.class),
- isA(FindCoordinatorRequest.class), isA(Integer.class))).thenThrow(new IOException("Connection refused"));
+ isA(FindCoordinatorRequest.class), isA(Integer.class)))
+ .thenThrow(new IOException("Connection refused"));
// interrupt this thread so that findCoordinator() won't keep looping
// and will throw an exception when going to pause
Thread.currentThread().interrupt();
- assertThatThrownBy(() -> gmsJoinLeave.findCoordinator()).isInstanceOf(SystemConnectException.class)
+ assertThatThrownBy(() -> gmsJoinLeave.findCoordinator())
+ .isInstanceOf(SystemConnectException.class)
.hasMessageContaining("Interrupted while trying to contact locators");
}