Kafka Integration Application (Fix Javadoc errors + review comments)
1. Refactored the application into two java projects api and app as per convention
2. Deleted the onos-app-gpb project. The proto files are consolidated in the
incubator-protobuf project as per suggestions.
3. Some code to translate ONOS Event pojo messages to GPB format.
4. Implementation of Subscribe and Unsubscribe APIs.
5. Minor changes due to review comments from 9212 and 9053
6. Refactored the proto fileso that its a 1:1 mapping between the core type to proto message.
Change-Id: I2bcc0de96150f838ccfe9e49293fe61d94062628
diff --git a/apps/kafka-integration/app/src/main/java/org/onosproject/kafkaintegration/listener/DeviceEventsListener.java b/apps/kafka-integration/app/src/main/java/org/onosproject/kafkaintegration/listener/DeviceEventsListener.java
new file mode 100644
index 0000000..22c4bf2
--- /dev/null
+++ b/apps/kafka-integration/app/src/main/java/org/onosproject/kafkaintegration/listener/DeviceEventsListener.java
@@ -0,0 +1,94 @@
+/**
+ * Copyright 2016 Open Networking Laboratory
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+
+ * http://www.apache.org/licenses/LICENSE-2.0
+
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.onosproject.kafkaintegration.listener;
+
+import static org.onosproject.kafkaintegration.api.dto.OnosEvent.Type.DEVICE;
+
+import org.onosproject.event.ListenerService;
+import org.onosproject.kafkaintegration.impl.Dispatcher;
+import org.onosproject.kafkaintegration.api.dto.OnosEvent.Type;
+import org.onosproject.kafkaintegration.converter.ConversionFactory;
+import org.onosproject.kafkaintegration.converter.EventConverter;
+import org.onosproject.net.device.DeviceEvent;
+import org.onosproject.net.device.DeviceListener;
+import org.onosproject.net.device.DeviceService;
+
+import com.google.protobuf.GeneratedMessage;
+
+/**
+ * Listens for ONOS Device events.
+ *
+ */
+final class DeviceEventsListener implements OnosEventListener {
+
+ private boolean listenerRunning = false;
+
+ private InnerListener listener = null;
+
+ // Exists to defeat instantiation
+ private DeviceEventsListener() {
+ }
+
+ private static class SingletonHolder {
+ private static final DeviceEventsListener INSTANCE =
+ new DeviceEventsListener();
+ }
+
+ /**
+ * Returns a static reference to the Listener Factory.
+ *
+ * @return singleton object
+ */
+ public static DeviceEventsListener getInstance() {
+ return SingletonHolder.INSTANCE;
+ }
+
+ @Override
+ public void startListener(Type e, ListenerService<?, ?> service) {
+ if (!listenerRunning) {
+ listener = new InnerListener();
+ DeviceService deviceService = (DeviceService) service;
+ deviceService.addListener(listener);
+ listenerRunning = true;
+ }
+ }
+
+ private class InnerListener implements DeviceListener {
+
+ @Override
+ public void event(DeviceEvent arg0) {
+
+ // Convert the event to GPB format
+ ConversionFactory conversionFactory =
+ ConversionFactory.getInstance();
+ EventConverter converter = conversionFactory.getConverter(DEVICE);
+ GeneratedMessage message = converter.convertToProtoMessage(arg0);
+
+ // Call Dispatcher and publish event
+ Dispatcher.getInstance().publish(DEVICE, message);
+ }
+ }
+
+ @Override
+ public void stopListener(Type e, ListenerService<?, ?> service) {
+ if (listenerRunning) {
+ DeviceService deviceService = (DeviceService) service;
+ deviceService.removeListener(listener);
+ listener = null;
+ listenerRunning = false;
+ }
+ }
+
+}