Skip to content

Commit 1833c9f

Browse files
committed
merge bug25631 into stable
2 parents 2a6e559 + 4910d23 commit 1833c9f

File tree

2 files changed

+23
-1
lines changed

2 files changed

+23
-1
lines changed

test/src/com/rabbitmq/client/test/BrokerTestCase.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -83,10 +83,15 @@ protected void releaseResources()
8383
protected void restart()
8484
throws IOException {
8585
tearDown();
86-
Host.executeCommand("cd ../rabbitmq-test; make restart-app");
86+
bareRestart();
8787
setUp();
8888
}
8989

90+
protected void bareRestart()
91+
throws IOException {
92+
Host.executeCommand("cd ../rabbitmq-test; make restart-app");
93+
}
94+
9095
public void openConnection()
9196
throws IOException {
9297
if (connection == null) {
Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,17 @@
1+
package com.rabbitmq.client.test.server;
2+
3+
import com.rabbitmq.client.test.BrokerTestCase;
4+
import com.rabbitmq.client.AMQP;
5+
import com.rabbitmq.client.Channel;
6+
import com.rabbitmq.client.Connection;
7+
8+
import java.io.IOException;
9+
10+
public class Shutdown extends BrokerTestCase {
11+
12+
public void testErrorOnShutdown() throws Exception {
13+
bareRestart();
14+
expectError(AMQP.CONNECTION_FORCED);
15+
}
16+
17+
}

0 commit comments

Comments
 (0)