1 files changed, 1 insertions, 29 deletions
diff --git a/bpmn/MSOCommonBPMN/src/main/java/org/openecomp/mso/client/dmaap/Consumer.java b/bpmn/MSOCommonBPMN/src/main/java/org/openecomp/mso/client/dmaap/Consumer.java
index f1bafde997..0e00ae5da8 100644
--- a/bpmn/MSOCommonBPMN/src/main/java/org/openecomp/mso/client/dmaap/Consumer.java
+++ b/bpmn/MSOCommonBPMN/src/main/java/org/openecomp/mso/client/dmaap/Consumer.java
@@ -22,33 +22,5 @@ package org.openecomp.mso.client.dmaap;
 
 public interface Consumer {
 
-	/**
-	 * Should this consumer continue to consume messages from the topic?
-	 * @return
-	 */
-	public boolean continuePolling();
-	/**
-	 * Process a message from a DMaaP topic
-	 * 
-	 * @param message
-	 * @throws Exception
-	 */
-	public void processMessage(String message) throws Exception;
-	/**
-	 * Has the request been accepted by the receiving system?
-	 * Should the consumer move to processing messages?
-	 * 
-	 * @param message
-	 * @return
-	 */
-	public boolean isAccepted(String message);
-	/**
-	 * The request id to filter messages on
-	 * @return
-	 */
-	public String getRequestId();
-	/**
-	 * Logic that defines when the consumer should stop processing messages
-	 */
-	public void stopProcessingMessages();
+	public Iterable<String> fetch();
 }