From fd8f9858fe2c7dfdee55a1e136a63fb01d1a3162 Mon Sep 17 00:00:00 2001
From: rn509j <rn509j@att.com>
Date: Sun, 1 Oct 2017 21:36:35 -0400
Subject: commiting code for test coverage

changed testcases

DMAAP-149
Signed-off-by: rn509j <rn509j@att.com>
Change-Id: I4dfeb3df44f85bfbd3a10ec1659c8618e31a10fb
---
 .../java/com/att/nsa/cambria/service/impl/EventsServiceImpl.java   | 7 +++++++
 .../java/com/att/nsa/cambria/service/impl/TopicServiceImpl.java    | 6 ++++++
 2 files changed, 13 insertions(+)

(limited to 'src/main/java/com')

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
-- 
cgit 1.2.3-korg