Kafka Application - Updated the Application to a Distributed Application
1. Distributed Work Queue to publish events.
2. Only one instance can publish to queue and only one instance can consume from the queue.
3. KafkaPublisherAdminService which does start,stop and restart a kafka producer.
3. Other cosmectic changes (some files have been renamed)
Change-Id: I15b2015ed303eae1c9fb9f4820fb14476726161e
diff --git a/apps/kafka-integration/api/src/main/java/org/onosproject/kafkaintegration/api/KafkaEventStorageService.java b/apps/kafka-integration/api/src/main/java/org/onosproject/kafkaintegration/api/KafkaEventStorageService.java
index ae6b720..0d0cc57 100644
--- a/apps/kafka-integration/api/src/main/java/org/onosproject/kafkaintegration/api/KafkaEventStorageService.java
+++ b/apps/kafka-integration/api/src/main/java/org/onosproject/kafkaintegration/api/KafkaEventStorageService.java
@@ -23,18 +23,16 @@
public interface KafkaEventStorageService {
/**
- * Inserts the Generated event into the local cache.
+ * Inserts the Onos Event into Distributed Work Queue.
*
* @param e the ONOS Event
- * @return true if the insertion was successful
*/
- boolean insertCacheEntry(OnosEvent e);
+ void publishEvent(OnosEvent event);
/**
- * Updates the counter with the most recently published event's sequence
- * number.
+ * Removes the Onos Event from the Distributed Work Queue.
*
- * @param sequenceNumber the updated value of sequence number.
+ * @return the Onos Event
*/
- void updateLastPublishedEntry(Long sequenceNumber);
+ OnosEvent consumeEvent();
}