From cb54da50943ca8f2b339444bb0ce73c0d777d257 Mon Sep 17 00:00:00 2001 From: Gurjeet Bedi Date: Fri, 22 Dec 2017 10:44:29 -0500 Subject: Better handling for exception logs Handling for dmaap not supporting offsets Issue-ID: AAI-552 Change-Id: I0af737d92861b7c6c22421a106d32c9b2c4fca7b Signed-off-by: Gurjeet Bedi --- .../java/org/onap/crud/service/CrudAsyncGraphDataService.java | 2 ++ .../java/org/onap/crud/service/CrudAsyncResponseConsumer.java | 9 ++++++++- 2 files changed, 10 insertions(+), 1 deletion(-) (limited to 'src/main/java/org') 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()); } -- cgit 1.2.3-korg