Add event client dependency

[aai/gizmo.git] / src / main / java / org / onap / crud / service / CrudAsyncResponseConsumer.java

diff --git a/src/main/java/org/onap/crud/service/CrudAsyncResponseConsumer.java b/src/main/java/org/onap/crud/service/CrudAsyncResponseConsumer.java
index da7e6e5..45ef7c6 100644 (file)
--- a/src/main/java/org/onap/crud/service/CrudAsyncResponseConsumer.java
+++ b/src/main/java/org/onap/crud/service/CrudAsyncResponseConsumer.java
@@ -25,12 +25,14 @@ 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;
 import org.onap.crud.logging.CrudServiceMsgs;
 
-import com.att.ecomp.event.api.EventConsumer;
+import org.onap.aai.event.api.EventConsumer;
 
 public class CrudAsyncResponseConsumer extends TimerTask {
 
@@ -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());
     }