diff options
author | adheli.tavares <adheli.tavares@est.tech> | 2023-12-18 17:52:52 +0000 |
---|---|---|
committer | adheli.tavares <adheli.tavares@est.tech> | 2023-12-18 17:53:45 +0000 |
commit | 875d5ca25cf09bbf80a8493639f2abfc501fc844 (patch) | |
tree | 712b196b451e4dbd3863c9656b1045d95a2b74fb /main/src/main/java | |
parent | ad4f8126b935377479c2bdf2f63d8b1f1661a49e (diff) |
Allow topics to be registered with lower case for kafka compability
Issue-ID: POLICY-4402
Change-Id: Ia2fabc3eed64bc8ecbdf1ab048a2101ee31daf04
Signed-off-by: adheli.tavares <adheli.tavares@est.tech>
Diffstat (limited to 'main/src/main/java')
-rw-r--r-- | main/src/main/java/org/onap/policy/pap/main/startstop/PapActivator.java | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/main/src/main/java/org/onap/policy/pap/main/startstop/PapActivator.java b/main/src/main/java/org/onap/policy/pap/main/startstop/PapActivator.java index 4d90d7e1..91fc21aa 100644 --- a/main/src/main/java/org/onap/policy/pap/main/startstop/PapActivator.java +++ b/main/src/main/java/org/onap/policy/pap/main/startstop/PapActivator.java @@ -68,15 +68,15 @@ public class PapActivator extends ServiceManagerContainer { // topic names @Getter @Value("${pap.topic.pdp-pap.name}") - private String topicPolicyPdpPap = "POLICY-PDP-PAP"; + private String topicPolicyPdpPap = "policy-pdp-pap"; @Getter @Value("${pap.topic.notification.name}") - private String topicPolicyNotification = "POLICY-NOTIFICATION"; + private String topicPolicyNotification = "policy-notification"; @Getter @Value("${pap.topic.heartbeat.name}") - private String topicPolicyHeartbeat = "POLICY-HEARTBEAT"; + private String topicPolicyHeartbeat = "policy-heartbeat"; private static final String[] MSG_TYPE_NAMES = { "messageName" }; private static final String[] REQ_ID_NAMES = { "response", "responseTo" }; @@ -267,6 +267,7 @@ public class PapActivator extends ServiceManagerContainer { * @param topic topic of interest */ private void registerMsgDispatcher(TopicListener dispatcher, String topic) { + topic = topic.toLowerCase(); for (final TopicSource source : TopicEndpointManager.getManager().getTopicSources(List.of(topic))) { source.register(dispatcher); } @@ -278,6 +279,7 @@ public class PapActivator extends ServiceManagerContainer { * @param topic topic of interest */ private void unregisterMsgDispatcher(TopicListener dispatcher, String topic) { + topic = topic.toLowerCase(); for (final TopicSource source : TopicEndpointManager.getManager().getTopicSources(List.of(topic))) { source.unregister(dispatcher); } |