diff --git a/spring-integration-amqp/src/test/java/org/springframework/integration/amqp/config/AmqpInboundGatewayParserTests.java b/spring-integration-amqp/src/test/java/org/springframework/integration/amqp/config/AmqpInboundGatewayParserTests.java index 1158c97fe2..50eca8de85 100644 --- a/spring-integration-amqp/src/test/java/org/springframework/integration/amqp/config/AmqpInboundGatewayParserTests.java +++ b/spring-integration-amqp/src/test/java/org/springframework/integration/amqp/config/AmqpInboundGatewayParserTests.java @@ -91,7 +91,11 @@ public class AmqpInboundGatewayParserTests { assertFalse(TestUtils.getPropertyValue(gateway, "messageListenerContainer.missingQueuesFatal", Boolean.class)); Object amqpTemplate = context.getBean("amqpTemplate"); assertSame(amqpTemplate, TestUtils.getPropertyValue(gateway, "amqpTemplate")); - assertEquals(new Address("fooExchange/barRoutingKey"), TestUtils.getPropertyValue(gateway, "defaultReplyTo")); + Address defaultReplyTo = TestUtils.getPropertyValue(gateway, "defaultReplyTo", Address.class); + Address expected = new Address("fooExchange/barRoutingKey"); + assertEquals(expected.getExchangeName(), defaultReplyTo.getExchangeName()); + assertEquals(expected.getRoutingKey(), defaultReplyTo.getRoutingKey()); + //TODO Address.equals() when IO goes to Spring AMQP 1.5.0.RELEASE } @SuppressWarnings("rawtypes")