diff options
Diffstat (limited to 'participant/participant-impl/participant-impl-acelement/src/test/java/org')
3 files changed, 5 insertions, 4 deletions
diff --git a/participant/participant-impl/participant-impl-acelement/src/test/java/org/onap/policy/clamp/acm/element/service/BridgeServiceTest.java b/participant/participant-impl/participant-impl-acelement/src/test/java/org/onap/policy/clamp/acm/element/service/BridgeServiceTest.java index cc62d8d15..aae8d5893 100644 --- a/participant/participant-impl/participant-impl-acelement/src/test/java/org/onap/policy/clamp/acm/element/service/BridgeServiceTest.java +++ b/participant/participant-impl/participant-impl-acelement/src/test/java/org/onap/policy/clamp/acm/element/service/BridgeServiceTest.java @@ -47,7 +47,7 @@ class BridgeServiceTest { assertThat(bridgeService.getType()).isEqualTo(ElementType.BRIDGE); var elementConfig = new ElementConfig(); - elementConfig.setElementId(new ToscaConceptIdentifier("onap.policy.clamp.ac.element2", "1.0.0")); + elementConfig.setReceiverId(new ToscaConceptIdentifier("onap.policy.clamp.ac.element2", "1.0.0")); bridgeService.active(elementConfig); bridgeService.handleMessage(new ElementStatus()); diff --git a/participant/participant-impl/participant-impl-acelement/src/test/java/org/onap/policy/clamp/acm/element/service/ConfigServiceTest.java b/participant/participant-impl/participant-impl-acelement/src/test/java/org/onap/policy/clamp/acm/element/service/ConfigServiceTest.java index 785673bae..156f7d3fc 100644 --- a/participant/participant-impl/participant-impl-acelement/src/test/java/org/onap/policy/clamp/acm/element/service/ConfigServiceTest.java +++ b/participant/participant-impl/participant-impl-acelement/src/test/java/org/onap/policy/clamp/acm/element/service/ConfigServiceTest.java @@ -39,7 +39,8 @@ class ConfigServiceTest { var elementConfig = new ElementConfig(); elementConfig.setTopicParameterGroup(new DmaapConfig()); elementConfig.getTopicParameterGroup().setTopicCommInfrastructure("dmaap"); - elementConfig.getTopicParameterGroup().setTopic("topic"); + elementConfig.getTopicParameterGroup().setListenerTopic("topic"); + elementConfig.getTopicParameterGroup().setPublisherTopic("topic"); elementConfig.getTopicParameterGroup().setServer("localhost"); elementConfig.getTopicParameterGroup().setFetchTimeout(1000); diff --git a/participant/participant-impl/participant-impl-acelement/src/test/java/org/onap/policy/clamp/acm/element/service/StarterServiceTest.java b/participant/participant-impl/participant-impl-acelement/src/test/java/org/onap/policy/clamp/acm/element/service/StarterServiceTest.java index ee58a352c..28af70de7 100644 --- a/participant/participant-impl/participant-impl-acelement/src/test/java/org/onap/policy/clamp/acm/element/service/StarterServiceTest.java +++ b/participant/participant-impl/participant-impl-acelement/src/test/java/org/onap/policy/clamp/acm/element/service/StarterServiceTest.java @@ -47,8 +47,8 @@ class StarterServiceTest { assertThat(starterService.getType()).isEqualTo(ElementType.STARTER); var elementConfig = new ElementConfig(); - elementConfig.setTimerSec(100); - elementConfig.setElementId(new ToscaConceptIdentifier("onap.policy.clamp.ac.element2", "1.0.0")); + elementConfig.setTimerMs(100); + elementConfig.setReceiverId(new ToscaConceptIdentifier("onap.policy.clamp.ac.element2", "1.0.0")); starterService.active(elementConfig); verify(messagePublisher, timeout(200).atLeastOnce()).publishMsg(any(ElementMessage.class)); starterService.deactivate(); |