diff options
author | rameshiyer27 <ramesh.murugan.iyer@est.tech> | 2022-08-26 10:56:31 +0100 |
---|---|---|
committer | rameshiyer27 <ramesh.murugan.iyer@est.tech> | 2022-08-26 15:19:59 +0100 |
commit | df9dc5ca6f5a6fed5af6c322a582d70d8114b21b (patch) | |
tree | b79b76c14515810e8fc10398727d251348818ecf /models/src | |
parent | e7beba3d152cb8df1809fbe8a644f227a441957e (diff) |
Add new topic for publishing events in Acm Element Impl
Listening and publishing on different topics for better readability of
logs and segregation of events between PDP and AC element.
Issue-ID: POLICY-4332
Signed-off-by: zrrmmua <ramesh.murugan.iyer@est.tech>
Change-Id: I7c44ba1498c73a8bd395ad54eeb09950c584156e
Diffstat (limited to 'models/src')
2 files changed, 5 insertions, 3 deletions
diff --git a/models/src/main/java/org/onap/policy/clamp/models/acm/messages/rest/element/DmaapConfig.java b/models/src/main/java/org/onap/policy/clamp/models/acm/messages/rest/element/DmaapConfig.java index 0d13bcda5..dad92afa9 100644 --- a/models/src/main/java/org/onap/policy/clamp/models/acm/messages/rest/element/DmaapConfig.java +++ b/models/src/main/java/org/onap/policy/clamp/models/acm/messages/rest/element/DmaapConfig.java @@ -26,7 +26,9 @@ import lombok.Data; public class DmaapConfig { private String server; - private String topic; + private String listenerTopic; + + private String publisherTopic; private Integer fetchTimeout; diff --git a/models/src/main/java/org/onap/policy/clamp/models/acm/messages/rest/element/ElementConfig.java b/models/src/main/java/org/onap/policy/clamp/models/acm/messages/rest/element/ElementConfig.java index d1f064823..c86f7f225 100644 --- a/models/src/main/java/org/onap/policy/clamp/models/acm/messages/rest/element/ElementConfig.java +++ b/models/src/main/java/org/onap/policy/clamp/models/acm/messages/rest/element/ElementConfig.java @@ -26,11 +26,11 @@ import org.onap.policy.models.tosca.authorative.concepts.ToscaConceptIdentifier; @Data public class ElementConfig { - private ToscaConceptIdentifier elementId; + private ToscaConceptIdentifier receiverId; private ElementType elementType; - private Integer timerSec; + private Integer timerMs; private DmaapConfig topicParameterGroup; } |