diff --git a/spring-integration-ws/src/main/resources/org/springframework/integration/ws/config/spring-integration-ws-2.1.xsd b/spring-integration-ws/src/main/resources/org/springframework/integration/ws/config/spring-integration-ws-2.1.xsd index ddb951fa93..f3775c8108 100644 --- a/spring-integration-ws/src/main/resources/org/springframework/integration/ws/config/spring-integration-ws-2.1.xsd +++ b/spring-integration-ws/src/main/resources/org/springframework/integration/ws/config/spring-integration-ws-2.1.xsd @@ -290,6 +290,14 @@ this list can also be simple patterns to be matched against the header names (e. + + + + Maximum time in milliseconds to wait for a reply from the downstream message flow initiated by this gateway. + This attribute is only relevant if at least some part of the downstream flow is asynchronous. + + + diff --git a/spring-integration-ws/src/test/java/org/springframework/integration/ws/config/WebServiceInboundGatewayParserTests-context.xml b/spring-integration-ws/src/test/java/org/springframework/integration/ws/config/WebServiceInboundGatewayParserTests-context.xml index b744082a69..aebf275d39 100644 --- a/spring-integration-ws/src/test/java/org/springframework/integration/ws/config/WebServiceInboundGatewayParserTests-context.xml +++ b/spring-integration-ws/src/test/java/org/springframework/integration/ws/config/WebServiceInboundGatewayParserTests-context.xml @@ -46,4 +46,11 @@ + + + + + + diff --git a/spring-integration-ws/src/test/java/org/springframework/integration/ws/config/WebServiceInboundGatewayParserTests.java b/spring-integration-ws/src/test/java/org/springframework/integration/ws/config/WebServiceInboundGatewayParserTests.java index 489c6df523..549fd69680 100644 --- a/spring-integration-ws/src/test/java/org/springframework/integration/ws/config/WebServiceInboundGatewayParserTests.java +++ b/spring-integration-ws/src/test/java/org/springframework/integration/ws/config/WebServiceInboundGatewayParserTests.java @@ -179,6 +179,16 @@ public class WebServiceInboundGatewayParserTests { assertEquals(testHeaderMapper, headerMapper); } + @Autowired @Qualifier("replyTimeoutGateway") + private SimpleWebServiceInboundGateway replyTimeoutGateway; + + @Test + public void testReplyTimeout() throws Exception { + DirectFieldAccessor accessor = new DirectFieldAccessor(replyTimeoutGateway); + Object replyTimeout = accessor.getPropertyValue("replyTimeout"); + assertEquals(1234L, replyTimeout); + } + @SuppressWarnings("unused") private static class TestHeaderMapper implements SoapHeaderMapper {