diff --git a/spring-integration-ip/src/main/resources/org/springframework/integration/ip/config/spring-integration-ip-2.0.xsd b/spring-integration-ip/src/main/resources/org/springframework/integration/ip/config/spring-integration-ip-2.0.xsd index 7e89fe622d..b4285f4a04 100644 --- a/spring-integration-ip/src/main/resources/org/springframework/integration/ip/config/spring-integration-ip-2.0.xsd +++ b/spring-integration-ip/src/main/resources/org/springframework/integration/ip/config/spring-integration-ip-2.0.xsd @@ -285,7 +285,7 @@ connections. - + If true, the factory will use java.nio.channel.SocketChannel for communication; @@ -301,6 +301,14 @@ performance and may use fewer threads. + + + +If true, instructs the factory to use direct buffers if possible; only applies if +using-nio is true. Refer to ByteBuffer javadocs for more information. + + + diff --git a/spring-integration-ip/src/test/java/org/springframework/integration/ip/config/ParserUnitTests-context.xml b/spring-integration-ip/src/test/java/org/springframework/integration/ip/config/ParserUnitTests-context.xml index 4572195901..024d34a439 100644 --- a/spring-integration-ip/src/test/java/org/springframework/integration/ip/config/ParserUnitTests-context.xml +++ b/spring-integration-ip/src/test/java/org/springframework/integration/ip/config/ParserUnitTests-context.xml @@ -296,6 +296,7 @@ single-use="true" task-executor="externalTE" pool-size="321" + using-direct-buffers="true" /> diff --git a/spring-integration-ip/src/test/java/org/springframework/integration/ip/config/ParserUnitTests.java b/spring-integration-ip/src/test/java/org/springframework/integration/ip/config/ParserUnitTests.java index b7dcf846e6..d66c203002 100644 --- a/spring-integration-ip/src/test/java/org/springframework/integration/ip/config/ParserUnitTests.java +++ b/spring-integration-ip/src/test/java/org/springframework/integration/ip/config/ParserUnitTests.java @@ -435,6 +435,7 @@ public class ParserUnitTests { assertEquals(true, dfa.getPropertyValue("singleUse")); assertSame(taskExecutor, dfa.getPropertyValue("taskExecutor")); assertEquals(321, dfa.getPropertyValue("poolSize")); + assertEquals(true, dfa.getPropertyValue("usingDirectBuffers")); } @Test @@ -453,6 +454,7 @@ public class ParserUnitTests { assertEquals(true, dfa.getPropertyValue("singleUse")); assertSame(taskExecutor, dfa.getPropertyValue("taskExecutor")); assertEquals(123, dfa.getPropertyValue("poolSize")); + assertEquals(true, dfa.getPropertyValue("usingDirectBuffers")); } @Test