summaryrefslogtreecommitdiffstats
path: root/src/main/java/com
diff options
context:
space:
mode:
authorrn509j <rn509j@att.com>2017-10-01 21:36:35 -0400
committerrn509j <rn509j@att.com>2017-10-01 22:26:36 -0400
commitfd8f9858fe2c7dfdee55a1e136a63fb01d1a3162 (patch)
treea94e58e1bac32562d0cb30f65663563a5d783d13 /src/main/java/com
parent2881443ed939d6d3c1a55719cca95ee9e7483165 (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.java7
-rw-r--r--src/main/java/com/att/nsa/cambria/service/impl/TopicServiceImpl.java6
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