aboutsummaryrefslogtreecommitdiffstats
path: root/container-messagebus/src/test
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2021-09-24 09:46:53 +0200
committerHenning Baldersheim <balder@yahoo-inc.com>2021-09-24 09:47:17 +0200
commit8fd1e2515449912e4594e09184357df67048b274 (patch)
tree74ff332edbe6d1d50a32c024bfb903ae4568f96a /container-messagebus/src/test
parent8b5c2f0197ec501e97a2b31dfea2e0fe3ac1ef85 (diff)
Stopping is server is a one way street.
Returning BUSY as a temporary error will cause retries, instead of fast-fail.
Diffstat (limited to 'container-messagebus/src/test')
-rw-r--r--container-messagebus/src/test/java/com/yahoo/messagebus/jdisc/MbusServerConformanceTest.java3
1 files changed, 2 insertions, 1 deletions
diff --git a/container-messagebus/src/test/java/com/yahoo/messagebus/jdisc/MbusServerConformanceTest.java b/container-messagebus/src/test/java/com/yahoo/messagebus/jdisc/MbusServerConformanceTest.java
index bf89f3869ed..2bdc15002ad 100644
--- a/container-messagebus/src/test/java/com/yahoo/messagebus/jdisc/MbusServerConformanceTest.java
+++ b/container-messagebus/src/test/java/com/yahoo/messagebus/jdisc/MbusServerConformanceTest.java
@@ -31,6 +31,7 @@ import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.TimeUnit;
import static com.yahoo.messagebus.ErrorCode.APP_FATAL_ERROR;
+import static com.yahoo.messagebus.ErrorCode.SEND_QUEUE_CLOSED;
import static com.yahoo.messagebus.ErrorCode.SESSION_BUSY;
import static org.hamcrest.CoreMatchers.is;
import static org.hamcrest.CoreMatchers.notNullValue;
@@ -50,7 +51,7 @@ public class MbusServerConformanceTest extends ServerProviderConformanceTest {
@Test
public void testContainerNotReadyException() throws Throwable {
new TestRunner().setRequestTimeout(100, TimeUnit.MILLISECONDS)
- .expectError(is(SESSION_BUSY))
+ .expectError(is(SEND_QUEUE_CLOSED))
.executeAndClose();
}