diff options
Diffstat (limited to 'src/main/java/org/onap/pomba/contextaggregator/config')
-rw-r--r-- | src/main/java/org/onap/pomba/contextaggregator/config/TransportConfig.java | 26 |
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); } + } |