Merge of new rebased code

[appc.git] / appc-adapters / appc-dmaap-adapter / appc-message-adapter-api / src / main / java / org / openecomp / appc / adapter / message / Consumer.java

diff --git a/appc-adapters/appc-dmaap-adapter/appc-dmaap-adapter-bundle/src/main/java/org/openecomp/appc/adapter/dmaap/Consumer.java b/appc-adapters/appc-dmaap-adapter/appc-message-adapter-api/src/main/java/org/openecomp/appc/adapter/message/Consumer.java
similarity index 93%
rename from appc-adapters/appc-dmaap-adapter/appc-dmaap-adapter-bundle/src/main/java/org/openecomp/appc/adapter/dmaap/Consumer.java
rename to appc-adapters/appc-dmaap-adapter/appc-message-adapter-api/src/main/java/org/openecomp/appc/adapter/message/Consumer.java
index 32034e5..e99f884 100644 (file)
--- a/appc-adapters/appc-dmaap-adapter/appc-dmaap-adapter-bundle/src/main/java/org/openecomp/appc/adapter/dmaap/Consumer.java
+++ b/appc-adapters/appc-dmaap-adapter/appc-message-adapter-api/src/main/java/org/openecomp/appc/adapter/message/Consumer.java
@@ -19,7 +19,7 @@
  * ============LICENSE_END=========================================================
  */
 
-package org.openecomp.appc.adapter.dmaap;
+package org.openecomp.appc.adapter.message;
 
 import java.util.List;
 
@@ -54,9 +54,6 @@ public interface Consumer {
      */
     public void updateCredentials(String apiKey, String apiSecret);
 
-    // TODO - Implement once Cambria allows you to set outside of constructor
-    // public void setFilter(String filter);
-
     /**
      * Creates a dmaap client using a https connection
      * 
@@ -65,4 +62,9 @@ public interface Consumer {
      */
     public void useHttps(boolean yes);
 
+    /**
+     * Closes the dmaap client https connection
+     */
+    void close();
+
 }