NO-JIRA fix unused parameter `durable` in AmqpClientTestSupport#sendMessages

This commit is contained in:
Jiri Danek 2018-08-07 16:42:04 +02:00 committed by Clebert Suconic
parent 7480452bdd
commit 05816fefab
1 changed files with 1 additions and 1 deletions

View File

@ -326,7 +326,7 @@ public class AmqpClientTestSupport extends AmqpTestSupport {
for (int i = 0; i < count; ++i) { for (int i = 0; i < count; ++i) {
AmqpMessage message = new AmqpMessage(); AmqpMessage message = new AmqpMessage();
message.setMessageId("MessageID:" + i); message.setMessageId("MessageID:" + i);
message.setDurable(true); message.setDurable(durable);
if (routingType != null) { if (routingType != null) {
message.setMessageAnnotation(AMQPMessageSupport.ROUTING_TYPE.toString(), routingType.getType()); message.setMessageAnnotation(AMQPMessageSupport.ROUTING_TYPE.toString(), routingType.getType());
} }