Skip to content

Commit 8e34cea

Browse files
committed
refactor: rename expectChannelError to expectError
since it works just as well for detecting connection errors
1 parent 4d56bb7 commit 8e34cea

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -151,7 +151,7 @@ public void checkShutdownSignal(int expectedCode, ShutdownSignalException sse) {
151151
}
152152
}
153153

154-
public void expectChannelError(int error) {
154+
public void expectError(int error) {
155155
try {
156156
channel.basicQos(0);
157157
fail("Expected channel error " + error);

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -28,14 +28,14 @@ public void testDoubleAck()
2828
channel.basicAck(tag, false);
2929
channel.basicAck(tag, false);
3030

31-
expectChannelError(AMQP.PRECONDITION_FAILED);
31+
expectError(AMQP.PRECONDITION_FAILED);
3232
}
3333

3434
public void testCrazyAck()
3535
throws IOException
3636
{
3737
select();
3838
channel.basicAck(123456, false);
39-
expectChannelError(AMQP.PRECONDITION_FAILED);
39+
expectError(AMQP.PRECONDITION_FAILED);
4040
}
4141
}

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -111,6 +111,6 @@ public void testReject()
111111
assertNull(channel.basicGet(q, false));
112112
channel.basicAck(tag1, false);
113113
channel.basicReject(tag3, false);
114-
expectChannelError(AMQP.PRECONDITION_FAILED);
114+
expectError(AMQP.PRECONDITION_FAILED);
115115
}
116116
}

0 commit comments

Comments
 (0)