bpmn/MSOCommonBPMN/src/main/java/org/openecomp/mso/client/dmaap/Consumer.java

   1 package org.openecomp.mso.client.dmaap;
   2
   3 public interface Consumer {
   4
   5         /**
   6          * Should this consumer continue to consume messages from the topic?
   7          * @return
   8          */
   9         public boolean continuePolling();
  10         /**
  11          * Process a message from a DMaaP topic
  12          *
  13          * @param message
  14          * @throws Exception
  15          */
  16         public void processMessage(String message) throws Exception;
  17         /**
  18          * Has the request been accepted by the receiving system?
  19          * Should the consumer move to processing messages?
  20          *
  21          * @param message
  22          * @return
  23          */
  24         public boolean isAccepted(String message);
  25         /**
  26          * The request id to filter messages on
  27          * @return
  28          */
  29         public String getRequestId();
  30         /**
  31          * Logic that defines when the consumer should stop processing messages
  32          */
  33         public void stopProcessingMessages();
  34 }