Removing deprecated DMAAP library

[policy/drools-pdp.git] / feature-pooling-messages / src / main / java / org / onap / policy / drools / pooling / TopicMessageManager.java

diff --git a/feature-pooling-dmaap/src/main/java/org/onap/policy/drools/pooling/DmaapManager.java b/feature-pooling-messages/src/main/java/org/onap/policy/drools/pooling/TopicMessageManager.java
similarity index 92%
rename from feature-pooling-dmaap/src/main/java/org/onap/policy/drools/pooling/DmaapManager.java
rename to feature-pooling-messages/src/main/java/org/onap/policy/drools/pooling/TopicMessageManager.java
index c0358f6..4c9b3f3 100644 (file)
--- a/feature-pooling-dmaap/src/main/java/org/onap/policy/drools/pooling/DmaapManager.java
+++ b/feature-pooling-messages/src/main/java/org/onap/policy/drools/pooling/TopicMessageManager.java
@@ -3,6 +3,7 @@
  * ONAP
  * ================================================================================
  * Copyright (C) 2018-2021 AT&T Intellectual Property. All rights reserved.
+ * Modifications Copyright (C) 2024 Nordix Foundation.
  * ================================================================================
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -31,15 +32,15 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 /**
- * Manages the internal DMaaP topic. Assumes all topics are managed by
- * {@link TopicEndpoint#manager}.
+ * Manages the internal topic. Assumes all topics are managed by
+ * {@link TopicEndpoint}.
  */
-public class DmaapManager {
+public class TopicMessageManager {
 
-    private static final Logger logger = LoggerFactory.getLogger(DmaapManager.class);
+    private static final Logger logger = LoggerFactory.getLogger(TopicMessageManager.class);
 
     /**
-     * Name of the DMaaP topic.
+     * Name of the topic.
      */
     @Getter
     private final String topic;
@@ -67,10 +68,10 @@ public class DmaapManager {
     /**
      * Constructs the manager, but does not start the source or sink.
      *
-     * @param topic name of the internal DMaaP topic
+     * @param topic name of the internal topic
      * @throws PoolingFeatureException if an error occurs
      */
-    public DmaapManager(String topic) throws PoolingFeatureException {
+    public TopicMessageManager(String topic) throws PoolingFeatureException {
 
         logger.info("initializing bus for topic {}", topic);
 
@@ -87,7 +88,7 @@ public class DmaapManager {
     }
 
     /**
-     * Finds the topic source associated with the internal DMaaP topic.
+     * Finds the topic source associated with the internal topic.
      *
      * @return the topic source
      * @throws PoolingFeatureException if the source doesn't exist or is not filterable
@@ -103,7 +104,7 @@ public class DmaapManager {
     }
 
     /**
-     * Finds the topic sink associated with the internal DMaaP topic.
+     * Finds the topic sink associated with the internal topic.
      *
      * @return the topic sink
      * @throws PoolingFeatureException if the sink doesn't exist