1 files changed, 25 insertions, 1 deletions
diff --git a/src/main/java/org/onap/pomba/contextaggregator/config/TransportConfig.java b/src/main/java/org/onap/pomba/contextaggregator/config/TransportConfig.java
index 12f0cc8..1532f43 100644
--- a/src/main/java/org/onap/pomba/contextaggregator/config/TransportConfig.java
+++ b/src/main/java/org/onap/pomba/contextaggregator/config/TransportConfig.java
@@ -17,18 +17,21 @@
  */
 package org.onap.pomba.contextaggregator.config;
 
+import java.util.Collection;
 import java.util.Properties;
+
 import org.onap.pomba.contextaggregator.publisher.EventPublisherFactory;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+
 import com.att.nsa.mr.client.MRClientFactory;
 import com.att.nsa.mr.client.MRConsumer;
+import com.att.nsa.mr.client.MRTopicManager;
 import com.att.nsa.mr.client.impl.MRConsumerImpl;
 
 @Configuration
 public class TransportConfig {
-
     @Bean
     public MRConsumer consumer(@Value("${transport.consume.host}") String host,
             @Value("${transport.consume.port}") String port, @Value("${transport.consume.topic}") String topic,
@@ -38,6 +41,7 @@ public class TransportConfig {
             @Value("${transport.consume.timeout}") int timeout, @Value("${transport.consume.batchsize}") int batchSize,
             @Value("${transport.consume.msglimit}") int msgLimit, @Value("${transport.consume.type}") String type) {
 
+
         String hostStr = host + ":" + port;
 
         final MRConsumer consumer = MRClientFactory.createConsumer(hostStr, topic, motsid, pass, consumerGroup,
@@ -51,6 +55,25 @@ public class TransportConfig {
     }
 
     @Bean
+    public MRTopicManager messageRouterTopicMgr (@Value("${transport.consume.host}") String host,
+            @Value("${transport.consume.port}") String port,
+            @Value("${transport.message-router.apiKey}") String apiKey,
+            @Value("${transport.message-router.apiSecret}") String apiSecret
+            ) {
+
+        String hostStr = host + ":" + port;
+        // Verify if all topics ()
+        Collection<String> hostSet = java.util.Arrays.asList(hostStr);
+        MRTopicManager mgr = MRClientFactory.createTopicManager(hostSet, apiKey, apiSecret);
+        return mgr;
+    }
+
+    @Bean
+    public String messageRouterRequiredPombaTopicList(@Value("${transport.message-router.requiredPombaTopics}") String requiredPombaTopics) {
+        return requiredPombaTopics;
+    }
+
+    @Bean
     public EventPublisherFactory publisherFactory(@Value("${transport.publish.host}") String host,
             @Value("${transport.publish.port}") String port, @Value("${transport.publish.topic}") String topic,
             @Value("${transport.publish.motsid}") String motsid, @Value("${transport.publish.pass}") String pass,
@@ -63,4 +86,5 @@ public class TransportConfig {
         return new EventPublisherFactory(hostStr, topic, motsid, pass, batchSize, maxAge, delay, type, partition,
                 retries);
     }
+
 }