From f6ac5c61bb6d509c9199a2f3daccaddd89fefdc5 Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Fri, 28 May 2010 21:56:22 +0000 Subject: [PATCH] Fix timing problem on UDP test case (send before ready to receive) --- .../integration/ip/udp/UdpUnicastEndToEndTests.java | 10 ++++++++++ .../integration/ip/udp/testIp-out-context.xml | 2 +- 2 files changed, 11 insertions(+), 1 deletion(-) diff --git a/spring-integration-ip/src/test/java/org/springframework/integration/ip/udp/UdpUnicastEndToEndTests.java b/spring-integration-ip/src/test/java/org/springframework/integration/ip/udp/UdpUnicastEndToEndTests.java index 1c5be5c980..a8d6ae332f 100644 --- a/spring-integration-ip/src/test/java/org/springframework/integration/ip/udp/UdpUnicastEndToEndTests.java +++ b/spring-integration-ip/src/test/java/org/springframework/integration/ip/udp/UdpUnicastEndToEndTests.java @@ -116,6 +116,16 @@ public class UdpUnicastEndToEndTests implements Runnable { public void run() { AbstractApplicationContext ctx = new ClassPathXmlApplicationContext( "testIp-in-context.xml", UdpUnicastEndToEndTests.class); + UnicastReceivingChannelAdapter inbound = ctx.getBean(UnicastReceivingChannelAdapter.class); + int n = 0; + try { + while (!inbound.isListening()) { + Thread.sleep(100); + if (n++ > 100) { + throw new RuntimeException("Failed to start listening"); + } + } + } catch (Exception e) { } while (okToRun) { try { readyToReceive.countDown(); diff --git a/spring-integration-ip/src/test/java/org/springframework/integration/ip/udp/testIp-out-context.xml b/spring-integration-ip/src/test/java/org/springframework/integration/ip/udp/testIp-out-context.xml index dd203b878d..f0786fde4d 100644 --- a/spring-integration-ip/src/test/java/org/springframework/integration/ip/udp/testIp-out-context.xml +++ b/spring-integration-ip/src/test/java/org/springframework/integration/ip/udp/testIp-out-context.xml @@ -35,7 +35,7 @@ acknowledge="true" ack-host="localhost" ack-port="22222" - ack-timeout="2000" + ack-timeout="10000" channel="outputChannel"/>