aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorGurjeet Bedi <gurjeetb@amdocs.com>2018-06-14 11:53:35 -0400
committerGurjeet Bedi <gurjeetb@amdocs.com>2018-06-14 11:54:19 -0400
commit95c897c3c85c305f676dc04adc2f167fecfc598b (patch)
tree9d9afa2ba5ed7bc085ef4617b276a4c23cb7301b
parentc6ebf9ae6c3e61d212ea058d773909cb78c4ce31 (diff)
Adding close as part of consumer
default close in case consumer needs Issue-ID: AAI-1205 Change-Id: I376e0e2a1ade4a2edefa3b052098618c15b1af1e Signed-off-by: Gurjeet Bedi <gurjeetb@amdocs.com>
-rw-r--r--event-client-api/src/main/java/org/onap/aai/event/api/EventConsumer.java6
1 files changed, 6 insertions, 0 deletions
diff --git a/event-client-api/src/main/java/org/onap/aai/event/api/EventConsumer.java b/event-client-api/src/main/java/org/onap/aai/event/api/EventConsumer.java
index 58ef8d1..6cb97e7 100644
--- a/event-client-api/src/main/java/org/onap/aai/event/api/EventConsumer.java
+++ b/event-client-api/src/main/java/org/onap/aai/event/api/EventConsumer.java
@@ -62,4 +62,10 @@ public interface EventConsumer {
* @throws Exception if the offsets could not be committed
*/
public void commitOffsets(long offset) throws Exception;
+
+ /**
+ * Closes the consumer
+ * @throws Exception
+ */
+ default void close() throws Exception {}
}