Personal-Twin/hapi-fhir-jpaserver-starter
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Update mdm test

Browse Source
This commit is contained in:
Tadgh
2021-02-17 15:34:39 -05:00
parent 9fef4fe1eb
commit f86391800b
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/test/java/ca/uhn/fhir/jpa/starter/ExampleServerR4IT.java
View File

@@ -30,6 +30,7 @@ import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import static ca.uhn.fhir.util.TestUtil.waitForSize; import static ca.uhn.fhir.util.TestUtil.waitForSize;
import static java.lang.Thread.sleep;
import static java.util.Comparator.comparing; import static java.util.Comparator.comparing;
import static org.awaitility.Awaitility.await; import static org.awaitility.Awaitility.await;
import static org.awaitility.Awaitility.pollInSameThread; import static org.awaitility.Awaitility.pollInSameThread;
@@ -76,7 +77,10 @@ public class ExampleServerR4IT {
// Wait until the MDM message has been processed // Wait until the MDM message has been processed
await().until(() -> getPatients().size(), equalTo(2)); await().until(() -> {
sleep(1000);
return getGoldenResourcePatient() != null;
});
Patient goldenRecord = getGoldenResourcePatient(); Patient goldenRecord = getGoldenResourcePatient();
// Verify that a golden record Patient was created // Verify that a golden record Patient was created
@@ -147,7 +151,7 @@ public class ExampleServerR4IT {
ourClient.create().resource(obs).execute(); ourClient.create().resource(obs).execute();
// Give some time for the subscription to deliver // Give some time for the subscription to deliver
Thread.sleep(2000); sleep(2000);
/* /*
* Ensure that we receive a ping on the websocket * Ensure that we receive a ping on the websocket