diff options
| author | Simon Willnauer <simonw@apache.org> | 2017-07-05 10:57:45 +0200 |
|---|---|---|
| committer | Simon Willnauer <simonw@apache.org> | 2017-07-05 11:23:14 +0200 |
| commit | 8e861b3896af9323bdb509ccc62fa3fe1446ee31 (patch) | |
| tree | 090147da791cf7be7c48111da756397fdfe240a4 /core/src | |
| parent | 7994703903cbdd5ffbfc969694a5426343e32d31 (diff) | |
[TEST] Add another valid exception that can occure with concurrent disconnects
Diffstat (limited to 'core/src')
| -rw-r--r-- | core/src/test/java/org/elasticsearch/transport/RemoteClusterServiceTests.java | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/core/src/test/java/org/elasticsearch/transport/RemoteClusterServiceTests.java b/core/src/test/java/org/elasticsearch/transport/RemoteClusterServiceTests.java index 1dbd935229..a535988c6d 100644 --- a/core/src/test/java/org/elasticsearch/transport/RemoteClusterServiceTests.java +++ b/core/src/test/java/org/elasticsearch/transport/RemoteClusterServiceTests.java @@ -29,6 +29,7 @@ import org.elasticsearch.test.ESTestCase; import org.elasticsearch.test.transport.MockTransportService; import org.elasticsearch.threadpool.TestThreadPool; import org.elasticsearch.threadpool.ThreadPool; +import org.hamcrest.Matchers; import java.io.IOException; import java.net.InetAddress; @@ -411,7 +412,8 @@ public class RemoteClusterServiceTests extends ESTestCase { failLatch.await(); assertNotNull(ex.get()); if (ex.get() instanceof IllegalStateException) { - assertEquals(ex.get().getMessage(), "no seed node left"); + assertThat(ex.get().getMessage(), Matchers.anyOf(Matchers.equalTo("no seed node left"), Matchers.startsWith + ("No node available for cluster:"))); } else { if (ex.get() instanceof TransportException == false) { // we have an issue for this see #25301 |