Add additional error messages to dmaap service

[appc.git] / services / appc-dmaap-service / appc-dmaap-event-service / src / main / java / org / onap / appc / services / dmaapService / PublishService.java

diff --git a/services/appc-dmaap-service/appc-dmaap-event-service/src/main/java/org/onap/appc/services/dmaapService/PublishService.java b/services/appc-dmaap-service/appc-dmaap-event-service/src/main/java/org/onap/appc/services/dmaapService/PublishService.java
index 1e1b9e7..cc20539 100644 (file)
--- a/services/appc-dmaap-service/appc-dmaap-event-service/src/main/java/org/onap/appc/services/dmaapService/PublishService.java
+++ b/services/appc-dmaap-service/appc-dmaap-event-service/src/main/java/org/onap/appc/services/dmaapService/PublishService.java
@@ -30,6 +30,10 @@ import org.onap.appc.adapter.factory.DmaapMessageAdapterFactoryImpl;
 import org.onap.appc.configuration.Configuration;
 import org.onap.appc.configuration.ConfigurationFactory;
 import org.springframework.stereotype.Service;
+
+import com.att.eelf.configuration.EELFLogger;
+import com.att.eelf.configuration.EELFManager;
+
 import org.onap.appc.adapter.message.MessageAdapterFactory;
 import org.onap.appc.adapter.message.Producer;
 import org.onap.appc.adapter.messaging.dmaap.http.HttpDmaapProducerImpl;
@@ -37,6 +41,8 @@ import org.onap.appc.adapter.messaging.dmaap.http.HttpDmaapProducerImpl;
 @Service
 public class PublishService {
     
+    private static final EELFLogger LOG = EELFManager.getInstance().getLogger(PublishService.class);
+    
     private Map<String,Producer> producers;
     private MessageAdapterFactory factory;
     Configuration configuration;
@@ -101,6 +107,14 @@ public class PublishService {
                     pool.add(name);
                 }
             }
+            if(pool.isEmpty()) {
+                LOG.error("There are no dmaap server pools. Check the property " + key + ".poolMembers");
+                return null;
+            }
+            if(writeTopic == null || writeTopic.isEmpty()) {
+                LOG.error("There is no write topic defined in the message request or in the properties file");
+                return null;
+            }
             return factory.createProducer(pool, writeTopic, apiKey, apiSecret);
         }
         return null;