From 20b807ef0e8296149ebf3e2c66aecea050eead39 Mon Sep 17 00:00:00 2001
From: Mark Fisher <markfisher@vmware.com>
Date: Mon, 18 Jan 2010 18:31:53 +0000
Subject: [PATCH] test contexts

---
 .../integration/ip/testIp-in-context.xml      | 52 ++++++++++++++
 .../integration/ip/testIp-out-context.xml     | 68 +++++++++++++++++++
 2 files changed, 120 insertions(+)
 create mode 100644 org.springframework.integration.ip/src/test/java/org/springframework/integration/ip/testIp-in-context.xml
 create mode 100644 org.springframework.integration.ip/src/test/java/org/springframework/integration/ip/testIp-out-context.xml

diff --git a/org.springframework.integration.ip/src/test/java/org/springframework/integration/ip/testIp-in-context.xml b/org.springframework.integration.ip/src/test/java/org/springframework/integration/ip/testIp-in-context.xml
new file mode 100644
index 0000000000..f069655e3c
--- /dev/null
+++ b/org.springframework.integration.ip/src/test/java/org/springframework/integration/ip/testIp-in-context.xml
@@ -0,0 +1,52 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<beans:beans xmlns="http://www.springframework.org/schema/integration"
+	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xmlns:beans="http://www.springframework.org/schema/beans"
+	xmlns:stream="http://www.springframework.org/schema/integration/stream"
+	xmlns:ip="http://www.springframework.org/schema/integration/ip"
+	xsi:schemaLocation="http://www.springframework.org/schema/beans
+			http://www.springframework.org/schema/beans/spring-beans.xsd
+			http://www.springframework.org/schema/integration
+			http://www.springframework.org/schema/integration/spring-integration.xsd
+			http://www.springframework.org/schema/integration/stream
+			http://www.springframework.org/schema/integration/stream/spring-integration-stream.xsd
+			http://www.springframework.org/schema/integration/ip
+			http://www.springframework.org/schema/integration/ip/spring-integration-ip.xsd">
+
+	<!--  
+		Play with the buffer size to force errors. If the checkLength property is 
+		set and this buffer is too small, we'll throw an exception.
+	-->
+	<ip:inbound-channel-adapter id="udpReceiver"
+		channel="udpToStdOutChannel"
+		protocol="udp"
+		port="11111"
+		receive-buffer-size="500"
+		multicast="false"
+		check-length="true" />
+
+	<ip:inbound-channel-adapter id="mcUdpReceiver"
+		channel="udpToStdOutChannel"
+		protocol="udp"
+		port="11112"
+		receive-buffer-size="500"
+		multicast="true"
+		multicast-address="225.6.7.8"
+		check-length="true" />
+
+ 	<channel id="udpToStdOutChannel">
+		<interceptors>
+			<beans:ref bean="stdoutCatcher"/>
+		</interceptors>
+	</channel>
+
+	<beans:bean id="stdoutCatcher" class = "org.springframework.integration.ip.StdOutCatcher"/>
+
+	<stream:stderr-channel-adapter id="stdout" channel="udpToStdOutChannel" append-newline="true"/> 
+
+	<beans:bean id="taskScheduler" class="org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler">
+		<beans:property name="daemon" value="true" />
+		<beans:property name="poolSize" value="2" />
+	</beans:bean>
+
+</beans:beans>
diff --git a/org.springframework.integration.ip/src/test/java/org/springframework/integration/ip/testIp-out-context.xml b/org.springframework.integration.ip/src/test/java/org/springframework/integration/ip/testIp-out-context.xml
new file mode 100644
index 0000000000..7928a73932
--- /dev/null
+++ b/org.springframework.integration.ip/src/test/java/org/springframework/integration/ip/testIp-out-context.xml
@@ -0,0 +1,68 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<beans:beans xmlns="http://www.springframework.org/schema/integration"
+	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xmlns:beans="http://www.springframework.org/schema/beans"
+	xmlns:stream="http://www.springframework.org/schema/integration/stream"
+	xmlns:ip="http://www.springframework.org/schema/integration/ip"
+	xsi:schemaLocation="http://www.springframework.org/schema/beans
+			http://www.springframework.org/schema/beans/spring-beans.xsd
+			http://www.springframework.org/schema/integration
+			http://www.springframework.org/schema/integration/spring-integration.xsd
+			http://www.springframework.org/schema/integration/stream
+			http://www.springframework.org/schema/integration/stream/spring-integration-stream.xsd
+			http://www.springframework.org/schema/integration/ip
+			http://www.springframework.org/schema/integration/ip/spring-integration-ip.xsd">
+
+	<stream:stdin-channel-adapter id="stdin" channel="outputChannel" >
+		<poller>
+			<interval-trigger interval="100" time-unit="MILLISECONDS"/>
+		</poller>
+	</stream:stdin-channel-adapter>
+
+	<channel id="inputChannel"/>
+
+	<channel id="outputChannel" />
+
+	<service-activator input-channel="inputChannel"
+	                   output-channel="outputChannel"
+	                   ref="testIp"
+	                   method="testIp"/>
+
+	<beans:bean id="testIp" class="org.springframework.integration.ip.TestIp"/>
+
+	<ip:outbound-channel-adapter id="udpSender" protocol="udp"
+		host="localhost"
+		port="11111"
+		check-length="true"
+		acknowledge="true"
+		ack-host="localhost"
+		ack-port="22222"
+		ack-timeout="5000"
+		channel="outputChannel"/>
+
+	<channel id="mcInputChannel"/>
+
+	<channel id="mcOutputChannel" />
+
+	<service-activator input-channel="mcInputChannel"
+	                   output-channel="mcOutputChannel"
+	                   ref="testIp"
+	                   method="testIp"/>
+
+	<ip:outbound-channel-adapter id="mcUdpSender" protocol="udp"
+		multicast="true"
+		time-to-live="2"
+		host="225.6.7.8"
+		port="11112"
+		check-length="true"
+		acknowledge="true"
+		ack-host="localhost"
+		ack-port="22223"
+		ack-timeout="50000"
+		channel="mcOutputChannel"/>
+		
+	<beans:bean id="taskScheduler" class="org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler">
+		<beans:property name="daemon" value="true" />
+	</beans:bean>
+ 
+</beans:beans>