Skip to content

Commit 31d035e

Browse files
author
Steve Powell
committed
Update test usage of handleBasicReturn(..) to handleReturn(..).
1 parent 99a92a8 commit 31d035e

File tree

4 files changed

+16
-16
lines changed

4 files changed

+16
-16
lines changed

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

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -58,12 +58,12 @@ private static boolean[] expected(String key) {
5858
@Override protected void setUp() throws IOException {
5959
super.setUp();
6060
channel.setReturnListener(new ReturnListener() {
61-
public void handleBasicReturn(int replyCode,
62-
String replyText,
63-
String exchange,
64-
String routingKey,
65-
AMQP.BasicProperties properties,
66-
byte[] body)
61+
public void handleReturn(int replyCode,
62+
String replyText,
63+
String exchange,
64+
String routingKey,
65+
AMQP.BasicProperties properties,
66+
byte[] body)
6767
throws IOException {
6868
gotReturn.set(true);
6969
}

test/src/com/rabbitmq/client/test/performance/ScalabilityTest.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -285,9 +285,9 @@ private float timeRouting(Channel channel, String[] routingKeys)
285285
boolean immdediate = true;
286286
final CountDownLatch latch = new CountDownLatch(params.messageCount);
287287
channel.setReturnListener(new ReturnListener() {
288-
public void handleBasicReturn(int replyCode, String replyText,
289-
String exchange, String routingKey,
290-
AMQP.BasicProperties properties, byte[] body) throws IOException {
288+
public void handleReturn(int replyCode, String replyText,
289+
String exchange, String routingKey,
290+
AMQP.BasicProperties properties, byte[] body) throws IOException {
291291
latch.countDown();
292292
}
293293
});

test/src/com/rabbitmq/examples/MulticastMain.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -265,12 +265,12 @@ public Producer(Channel channel, String exchangeName, String id,
265265
this.confirm = confirm;
266266
}
267267

268-
public synchronized void handleBasicReturn(int replyCode,
269-
String replyText,
270-
String exchange,
271-
String routingKey,
272-
AMQP.BasicProperties properties,
273-
byte[] body)
268+
public synchronized void handleReturn(int replyCode,
269+
String replyText,
270+
String exchange,
271+
String routingKey,
272+
AMQP.BasicProperties properties,
273+
byte[] body)
274274
throws IOException {
275275
returnCount++;
276276
}

test/src/com/rabbitmq/examples/TestMain.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -231,7 +231,7 @@ public void run() throws IOException {
231231
_ch1 = createChannel();
232232

233233
_ch1.setReturnListener(new ReturnListener() {
234-
public void handleBasicReturn(int replyCode, String replyText, String exchange, String routingKey, AMQP.BasicProperties properties, byte[] body)
234+
public void handleReturn(int replyCode, String replyText, String exchange, String routingKey, AMQP.BasicProperties properties, byte[] body)
235235
throws IOException {
236236
Method method = new AMQImpl.Basic.Return(replyCode, replyText, exchange, routingKey);
237237
log("Handling return with body " + new String(body));

0 commit comments

Comments
 (0)