X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pmproducer%2Fsrc%2Ftest%2Fjava%2Forg%2Foran%2Fpmproducer%2FApplicationTest.java;h=04e8eed584efece6c7dfa5bea10edf355c1c0549;hb=d806dbef4f43bb9c631c818e96c1a39e440c5e6c;hp=095a96ce33299ddf6c3ea7261623ce09e5b4207d;hpb=298969556b0f84de745a67e994a590d8b2a3de13;p=nonrtric%2Fplt%2Franpm.git diff --git a/pmproducer/src/test/java/org/oran/pmproducer/ApplicationTest.java b/pmproducer/src/test/java/org/oran/pmproducer/ApplicationTest.java index 095a96c..04e8eed 100644 --- a/pmproducer/src/test/java/org/oran/pmproducer/ApplicationTest.java +++ b/pmproducer/src/test/java/org/oran/pmproducer/ApplicationTest.java @@ -252,9 +252,10 @@ class ApplicationTest { } private void waitForRegistration() { + producerRegistrationTask.registerTypesAndProducer().block(); // Register producer, Register types await().untilAsserted(() -> assertThat(icsSimulatorController.testResults.registrationInfo).isNotNull()); - producerRegistrationTask.supervisionTask().block(); + producerRegistrationTask.registerTypesAndProducer().block(); assertThat(icsSimulatorController.testResults.registrationInfo.supportedTypeIds).hasSize(this.types.size()); assertThat(producerRegistrationTask.isRegisteredInIcs()).isTrue(); @@ -424,23 +425,6 @@ class ApplicationTest { await().untilAsserted(() -> assertThat(this.jobs.size()).isEqualTo(1)); } - @Test - void testReRegister() throws Exception { - // Wait foir register types and producer - waitForRegistration(); - - // Clear the registration, should trigger a re-register - icsSimulatorController.testResults.reset(); - producerRegistrationTask.supervisionTask().block(); - await().untilAsserted(() -> assertThat(icsSimulatorController.testResults.registrationInfo).isNotNull()); - assertThat(icsSimulatorController.testResults.registrationInfo.supportedTypeIds).hasSize(this.types.size()); - - // Just clear the registerred types, should trigger a re-register - icsSimulatorController.testResults.types.clear(); - await().untilAsserted(() -> assertThat(icsSimulatorController.testResults.registrationInfo.supportedTypeIds) - .hasSize(this.types.size())); - } - @Test @SuppressWarnings("squid:S2925") // "Thread.sleep" should not be used in tests. void testZZActuator() throws Exception {