From e157241cb7dfe023f57532f829e381644bdf18be Mon Sep 17 00:00:00 2001 From: sunil unnava Date: Tue, 11 Dec 2018 16:25:26 -0500 Subject: add configurable default partitions and replicas Issue-ID: DMAAP-903 Change-Id: Iabb3da85c3e42ddf68d049e6a8164449f7be8296 Signed-off-by: sunil unnava --- .../mr/cambria/service/impl/TopicServiceImplTest.java | 18 +++++++++++++++++- 1 file changed, 17 insertions(+), 1 deletion(-) (limited to 'src/test/java') diff --git a/src/test/java/org/onap/dmaap/mr/cambria/service/impl/TopicServiceImplTest.java b/src/test/java/org/onap/dmaap/mr/cambria/service/impl/TopicServiceImplTest.java index e5d3233..7cbdf79 100644 --- a/src/test/java/org/onap/dmaap/mr/cambria/service/impl/TopicServiceImplTest.java +++ b/src/test/java/org/onap/dmaap/mr/cambria/service/impl/TopicServiceImplTest.java @@ -141,6 +141,10 @@ public class TopicServiceImplTest { when(PropertiesMapBean.getProperty(CambriaConstants.msgRtr_prop, "enforced.topic.name.AAF")) .thenReturn("enfTopicName"); + when(PropertiesMapBean.getProperty(CambriaConstants.msgRtr_prop, "default.partitions")) + .thenReturn("1"); + when(PropertiesMapBean.getProperty(CambriaConstants.msgRtr_prop, "default.replicas")) + .thenReturn("1"); when(httpServReq.getHeader("AppName")).thenReturn("MyApp"); when(dmaapContext.getRequest()).thenReturn(httpServReq); @@ -165,7 +169,11 @@ public class TopicServiceImplTest { when(PropertiesMapBean.getProperty(CambriaConstants.msgRtr_prop, "enforced.topic.name.AAF")) .thenReturn("enfTopicName"); - + when(PropertiesMapBean.getProperty(CambriaConstants.msgRtr_prop, "default.partitions")) + .thenReturn("1"); + when(PropertiesMapBean.getProperty(CambriaConstants.msgRtr_prop, "default.replicas")) + .thenReturn("1"); + when(dmaapContext.getRequest()).thenReturn(httpServReq); when(dmaapContext.getResponse()).thenReturn(httpServRes); @@ -208,6 +216,10 @@ public class TopicServiceImplTest { when(PropertiesMapBean.getProperty(CambriaConstants.msgRtr_prop, "enforced.topic.name.AAF")) .thenReturn("enfTopicName"); + when(PropertiesMapBean.getProperty(CambriaConstants.msgRtr_prop, "default.partitions")) + .thenReturn("1"); + when(PropertiesMapBean.getProperty(CambriaConstants.msgRtr_prop, "default.replicas")) + .thenReturn("1"); when(httpServReq.getHeader("Authorization")).thenReturn(null); when(dmaapContext.getRequest()).thenReturn(httpServReq); @@ -232,6 +244,10 @@ public class TopicServiceImplTest { when(PropertiesMapBean.getProperty(CambriaConstants.msgRtr_prop, "enforced.topic.name.AAF")) .thenReturn("enfTopicName"); + when(PropertiesMapBean.getProperty(CambriaConstants.msgRtr_prop, "default.partitions")) + .thenReturn("1"); + when(PropertiesMapBean.getProperty(CambriaConstants.msgRtr_prop, "default.replicas")) + .thenReturn("1"); when(httpServReq.getHeader("Authorization")).thenReturn("Authorization"); when(dmaapContext.getRequest()).thenReturn(httpServReq); -- cgit 1.2.3-korg