Skip to content

Commit 0f5f8ab

Browse files
committed
refactor: use the helper function
1 parent 3fff917 commit 0f5f8ab

File tree

1 file changed

+2
-8
lines changed

1 file changed

+2
-8
lines changed

test/src/com/rabbitmq/client/test/functional/Recover.java

Lines changed: 2 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -117,19 +117,13 @@ public void testNoRedeliveryWithAutoAck()
117117
throws IOException, InterruptedException {
118118
verifyNoRedeliveryWithAutoAck(recoverSync);
119119
}
120-
120+
121121
public void testRequeueFalseNotSupported() throws Exception {
122122
try {
123123
channel.basicRecover(false);
124124
fail("basicRecover(false) should not be supported");
125125
} catch(IOException ioe) {
126-
ShutdownSignalException sse =
127-
(ShutdownSignalException) ioe.getCause();
128-
Command reason = (Command) sse.getReason();
129-
AMQP.Connection.Close close =
130-
(AMQP.Connection.Close) reason.getMethod();
131-
assertEquals("NOT_IMPLEMENTED - requeue=false",
132-
close.getReplyText());
126+
checkShutdownSignal(AMQP.NOT_IMPLEMENTED, ioe);
133127
}
134128
}
135129
}

0 commit comments

Comments
 (0)