Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Async AMQP Test - Always Get the Ack First

Browse Source
This commit is contained in:
Gary Russell
2016-04-22 12:33:48 -04:00
parent c1092e7f15
commit a98ce143e2
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-integration-amqp/src/test/java/org/springframework/integration/amqp/outbound/AsyncAmqpGatewayTests.java
View File

@@ -163,14 +163,16 @@ public class AsyncAmqpGatewayTests {
});
message = MessageBuilder.withPayload("bar").setErrorChannel(errorChannel).build();
gateway.handleMessage(message);
assertNull(errorChannel.receive(100));
ack = ackChannel.receive(10000);
assertNotNull(ack);
assertNull(errorChannel.receive(100));
gateway.setRequiresReply(true);
message = MessageBuilder.withPayload("baz").setErrorChannel(errorChannel).build();
gateway.handleMessage(message);
ack = ackChannel.receive(10000);
assertNotNull(ack);
received = errorChannel.receive(10000);
assertThat(received, instanceOf(ErrorMessage.class));
ErrorMessage error = (ErrorMessage) received;
@@ -178,8 +180,6 @@ public class AsyncAmqpGatewayTests {
assertThat(error.getPayload().getCause(), instanceOf(AmqpReplyTimeoutException.class));
asyncTemplate.setReceiveTimeout(30000);
receiver.setMessageListener(messageListener);
ack = ackChannel.receive(10000);
assertNotNull(ack);
// error on sending result
DirectChannel errorForce = new DirectChannel();