diff options
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 |