From 464fa8ac4af72535af4ec22935448c4b978350c1 Mon Sep 17 00:00:00 2001
From: Robert von Burg <eitch@eitchnet.ch>
Date: Tue, 16 May 2017 15:39:15 +0200
Subject: [PATCH] [Minor] fixed broken test

---
 .../postgresql/dao/test/ObserverUpdateTest.java     | 13 ++++++++-----
 1 file changed, 8 insertions(+), 5 deletions(-)

diff --git a/li.strolch.persistence.postgresql/src/test/java/li/strolch/persistence/postgresql/dao/test/ObserverUpdateTest.java b/li.strolch.persistence.postgresql/src/test/java/li/strolch/persistence/postgresql/dao/test/ObserverUpdateTest.java
index dec3ee3be..b1fcd222b 100644
--- a/li.strolch.persistence.postgresql/src/test/java/li/strolch/persistence/postgresql/dao/test/ObserverUpdateTest.java
+++ b/li.strolch.persistence.postgresql/src/test/java/li/strolch/persistence/postgresql/dao/test/ObserverUpdateTest.java
@@ -29,6 +29,10 @@ import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
+import org.junit.AfterClass;
+import org.junit.BeforeClass;
+import org.junit.Test;
+
 import li.strolch.agent.api.Observer;
 import li.strolch.agent.api.StrolchRealm;
 import li.strolch.model.Order;
@@ -43,10 +47,6 @@ import li.strolch.runtime.StrolchConstants;
 import li.strolch.runtime.privilege.PrivilegeHandler;
 import li.strolch.testbase.runtime.RuntimeMock;
 
-import org.junit.AfterClass;
-import org.junit.BeforeClass;
-import org.junit.Test;
-
 /**
  * @author Robert von Burg <eitch@eitchnet.ch>
  */
@@ -111,7 +111,7 @@ public class ObserverUpdateTest {
 	}
 
 	@Test
-	public void shouldReceiveUpdates() {
+	public void shouldReceiveUpdates() throws InterruptedException {
 
 		// register an observer for orders and resources
 		ElementAddedObserver observer = new ElementAddedObserver();
@@ -136,6 +136,9 @@ public class ObserverUpdateTest {
 			tx.commitOnClose();
 		}
 
+		// observer updates are async...
+		Thread.sleep(100L);
+
 		assertEquals(2, observer.results.size());
 		assertEquals(1, observer.results.get(Tags.ORDER).getCreated().size());
 		assertEquals(1, observer.results.get(Tags.RESOURCE).getCreated().size());