X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=pmproducer%2Fsrc%2Ftest%2Fjava%2Forg%2Foran%2Fpmproducer%2FApplicationTest.java;fp=pmproducer%2Fsrc%2Ftest%2Fjava%2Forg%2Foran%2Fpmproducer%2FApplicationTest.java;h=dd38ffcfd8517fef1946aeb3f5d1dba4a0e09ef0;hb=890c93c9bae2113d99f027b166319703c67c278f;hp=8cba2cac3fa995f7a5deca277b0a681bc6aede35;hpb=ebd1c0b01fb80f1313678c777d4b1cb46800c23d;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 8cba2ca..dd38ffc 100644 --- a/pmproducer/src/test/java/org/oran/pmproducer/ApplicationTest.java +++ b/pmproducer/src/test/java/org/oran/pmproducer/ApplicationTest.java @@ -257,9 +257,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(); @@ -429,23 +430,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 {