diff options
Diffstat (limited to 'src/main/java')
| -rw-r--r-- | src/main/java/org/onap/dmaap/dbcapi/model/MirrorMaker.java | 5 | ||||
| -rw-r--r-- | src/main/java/org/onap/dmaap/dbcapi/service/MR_ClusterService.java | 8 |
2 files changed, 10 insertions, 3 deletions
diff --git a/src/main/java/org/onap/dmaap/dbcapi/model/MirrorMaker.java b/src/main/java/org/onap/dmaap/dbcapi/model/MirrorMaker.java index 1e381b8..9f6f402 100644 --- a/src/main/java/org/onap/dmaap/dbcapi/model/MirrorMaker.java +++ b/src/main/java/org/onap/dmaap/dbcapi/model/MirrorMaker.java @@ -194,7 +194,10 @@ public class MirrorMaker extends DmaapObject { public void addTopic( String topic ) { - topics.add(topic); + if ( ! topics.contains(topic)) { + topics.add(topic); + } + logger.info( "Mirrormaker.addTopic: topic=" + topic + " . Now have " + topics.size() + " topics" ); } public int getTopicCount() { diff --git a/src/main/java/org/onap/dmaap/dbcapi/service/MR_ClusterService.java b/src/main/java/org/onap/dmaap/dbcapi/service/MR_ClusterService.java index 2dae579..ed57279 100644 --- a/src/main/java/org/onap/dmaap/dbcapi/service/MR_ClusterService.java +++ b/src/main/java/org/onap/dmaap/dbcapi/service/MR_ClusterService.java @@ -77,8 +77,12 @@ public class MR_ClusterService extends BaseLoggingClass { DcaeLocationService locations = new DcaeLocationService(); List<MR_Cluster> result = new ArrayList<MR_Cluster>(); for( MR_Cluster c: mr_clusters.values() ) { - if ( locations.getDcaeLocation(c.getDcaeLocationName()).isCentral() ) { - result.add(c); + try { + if ( locations.getDcaeLocation(c.getDcaeLocationName()).isCentral() ) { + result.add(c); + } + } catch ( NullPointerException npe ) { + logger.warn( "Failed test isCentral for location:" + c.getDcaeLocationName() ); } } return result; |