diff --git a/spring-integration-zookeeper/src/test/java/org/springframework/integration/zookeeper/lock/ZkLockRegistryTests.java b/spring-integration-zookeeper/src/test/java/org/springframework/integration/zookeeper/lock/ZkLockRegistryTests.java
index e5443f20e4..3cc9f19260 100644
--- a/spring-integration-zookeeper/src/test/java/org/springframework/integration/zookeeper/lock/ZkLockRegistryTests.java
+++ b/spring-integration-zookeeper/src/test/java/org/springframework/integration/zookeeper/lock/ZkLockRegistryTests.java
@@ -18,6 +18,7 @@ package org.springframework.integration.zookeeper.lock;
 
 import static org.hamcrest.Matchers.containsString;
 import static org.hamcrest.Matchers.instanceOf;
+import static org.hamcrest.Matchers.lessThan;
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertFalse;
 import static org.junit.Assert.assertNotSame;
@@ -332,7 +333,7 @@ public class ZkLockRegistryTests extends ZookeeperTestSupport {
 		Lock lock2 = registry.obtain("bar");
 
 		assertFalse("Should not have been able to lock with zookeeper server stopped!",
-					lock2.tryLock(1, TimeUnit.SECONDS));
+				lock2.tryLock(1, TimeUnit.SECONDS));
 
 		testingServer.restart();
 
@@ -355,13 +356,17 @@ public class ZkLockRegistryTests extends ZookeeperTestSupport {
 	@Test
 	public void testTryLock() throws Exception {
 		ZookeeperLockRegistry registry = new ZookeeperLockRegistry(this.client);
-		Lock lock = registry.obtain("foo");
+		for (int i = 0; i < 10; i++) {
+			Lock lock = registry.obtain("foo");
 
-		assertTrue(lock.tryLock());
-		lock.unlock();
+			int n = 0;
+			while (!lock.tryLock() && n++ < 100) {
+				Thread.sleep(100);
+			}
+			assertThat(n, lessThan(100));
 
-		assertTrue(lock.tryLock());
-		lock.unlock();
+			lock.unlock();
+		}
 
 		registry.destroy();
 	}