diff options
| author |   rn509j <rn509j@att.com> | 2017-10-01 21:36:35 -0400 |
|---|---|---|
| committer | rn509j <rn509j@att.com> | 2017-10-01 22:26:36 -0400 |
| commit | fd8f9858fe2c7dfdee55a1e136a63fb01d1a3162 (patch) | |
| tree | a94e58e1bac32562d0cb30f65663563a5d783d13 /src/main/java/com | |
| parent | 2881443ed939d6d3c1a55719cca95ee9e7483165 (diff) | |
commiting code for test coveragev1.0.01.0.0-ONAP1.0.0-Amsterdam
changed testcases
DMAAP-149
Signed-off-by: rn509j <rn509j@att.com>
Change-Id: I4dfeb3df44f85bfbd3a10ec1659c8618e31a10fb
Diffstat (limited to 'src/main/java/com')
| -rw-r--r-- | src/main/java/com/att/nsa/cambria/service/impl/EventsServiceImpl.java | 7 | ||||
| -rw-r--r-- | src/main/java/com/att/nsa/cambria/service/impl/TopicServiceImpl.java | 6 |
2 files changed, 13 insertions, 0 deletions
diff --git a/src/main/java/com/att/nsa/cambria/service/impl/EventsServiceImpl.java b/src/main/java/com/att/nsa/cambria/service/impl/EventsServiceImpl.java index 3386f19..e99def5 100644 --- a/src/main/java/com/att/nsa/cambria/service/impl/EventsServiceImpl.java +++ b/src/main/java/com/att/nsa/cambria/service/impl/EventsServiceImpl.java @@ -95,6 +95,10 @@ public class EventsServiceImpl implements EventsService { //@Value("${metrics.send.cambria.topic}") //private String metricsTopic; + public void setErrorMessages(DMaaPErrorMessages errorMessages) { + this.errorMessages = errorMessages; + } + /** * @param ctx * @param topic @@ -113,6 +117,9 @@ public class EventsServiceImpl implements EventsService { final long startTime = System.currentTimeMillis(); final HttpServletRequest req = ctx.getRequest(); + if(clientId == null) + throw new NullPointerException(); + boolean isAAFTopic=false; // was this host blacklisted? final String remoteAddr = Utils.getRemoteAddress(ctx);; diff --git a/src/main/java/com/att/nsa/cambria/service/impl/TopicServiceImpl.java b/src/main/java/com/att/nsa/cambria/service/impl/TopicServiceImpl.java index 658523d..c12be2f 100644 --- a/src/main/java/com/att/nsa/cambria/service/impl/TopicServiceImpl.java +++ b/src/main/java/com/att/nsa/cambria/service/impl/TopicServiceImpl.java @@ -70,10 +70,16 @@ public class TopicServiceImpl implements TopicService { @Autowired private DMaaPErrorMessages errorMessages; + + //@Value("${msgRtr.topicfactory.aaf}") //private String mrFactory; + public void setErrorMessages(DMaaPErrorMessages errorMessages) { + this.errorMessages = errorMessages; + } + /** * @param dmaapContext * @throws JSONException |