summaryrefslogtreecommitdiffstats
path: root/src/main
diff options
context:
space:
mode:
authorGurjeet Bedi <gurjeetb@amdocs.com>2017-12-22 10:44:29 -0500
committerGurjeet Bedi <gurjeetb@amdocs.com>2017-12-22 10:45:46 -0500
commitcb54da50943ca8f2b339444bb0ce73c0d777d257 (patch)
treedcdcd7c6643c7046ffa4461f07a7e486bb1c1533 /src/main
parent0e7b5a7e16a4f807580b152f3de766d1512543f1 (diff)
Better handling for exception logs
Handling for dmaap not supporting offsets Issue-ID: AAI-552 Change-Id: I0af737d92861b7c6c22421a106d32c9b2c4fca7b Signed-off-by: Gurjeet Bedi <gurjeetb@amdocs.com>
Diffstat (limited to 'src/main')
-rw-r--r--src/main/java/org/onap/crud/service/CrudAsyncGraphDataService.java2
-rw-r--r--src/main/java/org/onap/crud/service/CrudAsyncResponseConsumer.java9
2 files changed, 10 insertions, 1 deletions
diff --git a/src/main/java/org/onap/crud/service/CrudAsyncGraphDataService.java b/src/main/java/org/onap/crud/service/CrudAsyncGraphDataService.java
index 16f054e..360a7dc 100644
--- a/src/main/java/org/onap/crud/service/CrudAsyncGraphDataService.java
+++ b/src/main/java/org/onap/crud/service/CrudAsyncGraphDataService.java
@@ -161,6 +161,8 @@ public class CrudAsyncGraphDataService extends AbstractGraphDataService {
} catch (Exception e) {
throw new CrudException("Error publishing request " + event.getTransactionId() + " Cause: " + e.getMessage(), Status.INTERNAL_SERVER_ERROR);
}
+
+ logger.debug(CrudServiceMsgs.ASYNC_DATA_SERVICE_INFO, "Event Sent ="+event.toJson());
logger.info(CrudServiceMsgs.ASYNC_DATA_SERVICE_INFO,
"Event submitted of type: " + event.getObjectType() + " with key: " + event.getObjectKey()
diff --git a/src/main/java/org/onap/crud/service/CrudAsyncResponseConsumer.java b/src/main/java/org/onap/crud/service/CrudAsyncResponseConsumer.java
index da7e6e5..905fe15 100644
--- a/src/main/java/org/onap/crud/service/CrudAsyncResponseConsumer.java
+++ b/src/main/java/org/onap/crud/service/CrudAsyncResponseConsumer.java
@@ -25,6 +25,8 @@ package org.onap.crud.service;
import java.util.TimerTask;
+import javax.naming.OperationNotSupportedException;
+
import org.onap.aai.cl.api.Logger;
import org.onap.aai.cl.eelf.LoggerFactory;
import org.onap.crud.event.GraphEvent;
@@ -107,7 +109,12 @@ public class CrudAsyncResponseConsumer extends TimerTask {
try {
asyncResponseConsumer.commitOffsets();
- } catch (Exception e) {
+ }
+ catch(OperationNotSupportedException e) {
+ //Dmaap doesnt support commit with offset
+ logger.debug(CrudServiceMsgs.ASYNC_RESPONSE_CONSUMER_ERROR, e.getMessage());
+ }
+ catch (Exception e) {
logger.error(CrudServiceMsgs.ASYNC_RESPONSE_CONSUMER_ERROR, e.getMessage());
}