diff --git a/org.springframework.integration/src/main/resources/org/springframework/integration/config/xml/spring-integration-2.0.xsd b/org.springframework.integration/src/main/resources/org/springframework/integration/config/xml/spring-integration-2.0.xsd index bb7518543f..0143b2bcd0 100644 --- a/org.springframework.integration/src/main/resources/org/springframework/integration/config/xml/spring-integration-2.0.xsd +++ b/org.springframework.integration/src/main/resources/org/springframework/integration/config/xml/spring-integration-2.0.xsd @@ -34,6 +34,13 @@ + @@ -128,7 +135,7 @@ Capacity for this queue. Default capacity is 0 which means - this queue will accumulate as many messages as memory allows. + this queue will accumulate as many messages as memory allows. @@ -446,13 +453,25 @@ - + + + + + + + @@ -506,14 +525,26 @@ - + + + + + + + - + @@ -528,6 +559,11 @@ + + + - + - - - - - + + + - - diff --git a/org.springframework.integration/src/test/java/org/springframework/integration/gateway/GatewayInvokingMessageHandlerTests-context.xml b/org.springframework.integration/src/test/java/org/springframework/integration/gateway/GatewayInvokingMessageHandlerTests-context.xml index 188f21cac0..8c04ebe14d 100644 --- a/org.springframework.integration/src/test/java/org/springframework/integration/gateway/GatewayInvokingMessageHandlerTests-context.xml +++ b/org.springframework.integration/src/test/java/org/springframework/integration/gateway/GatewayInvokingMessageHandlerTests-context.xml @@ -27,6 +27,16 @@ + + + + + + + + + + diff --git a/org.springframework.integration/src/test/java/org/springframework/integration/gateway/GatewayInvokingMessageHandlerTests.java b/org.springframework.integration/src/test/java/org/springframework/integration/gateway/GatewayInvokingMessageHandlerTests.java index 503b2f7fc5..05f7413a84 100644 --- a/org.springframework.integration/src/test/java/org/springframework/integration/gateway/GatewayInvokingMessageHandlerTests.java +++ b/org.springframework.integration/src/test/java/org/springframework/integration/gateway/GatewayInvokingMessageHandlerTests.java @@ -54,7 +54,7 @@ public class GatewayInvokingMessageHandlerTests { public void validateGatewayInTheChainViaChannel() { output.subscribe(new MessageHandler() { public void handleMessage(Message message) { - Assert.assertEquals("echo:echo:hello", message.getPayload()); + Assert.assertEquals("echo:echo:echo:hello", message.getPayload()); Assert.assertEquals("foo", message.getHeaders().get("foo")); Assert.assertEquals("oleg", message.getHeaders().get("name")); } @@ -66,13 +66,13 @@ public class GatewayInvokingMessageHandlerTests { public void validateGatewayInTheChainViaAnotherGateway() { output.subscribe(new MessageHandler() { public void handleMessage(Message message) { - Assert.assertEquals("echo:echo:hello", message.getPayload()); + Assert.assertEquals("echo:echo:echo:hello", message.getPayload()); Assert.assertEquals("foo", message.getHeaders().get("foo")); Assert.assertEquals("oleg", message.getHeaders().get("name")); } }); String result = gateway.sendRecieve("hello"); - Assert.assertEquals("echo:echo:hello", result); + Assert.assertEquals("echo:echo:echo:hello", result); } public static interface SimpleGateway {