Initial opendaylight infrastructure commit!!

[controller.git] / opendaylight / logging / bridge / src / main / java / org / opendaylight / controller / logging / bridge / internal / Activator.java

diff --git a/opendaylight/logging/bridge/src/main/java/org/opendaylight/controller/logging/bridge/internal/Activator.java b/opendaylight/logging/bridge/src/main/java/org/opendaylight/controller/logging/bridge/internal/Activator.java
new file mode 100644 (file)
index 0000000..90908ef
--- /dev/null
+++ b/opendaylight/logging/bridge/src/main/java/org/opendaylight/controller/logging/bridge/internal/Activator.java
@@ -0,0 +1,80 @@
+
+/*
+ * Copyright (c) 2013 Cisco Systems, Inc. and others.  All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
+
+package org.opendaylight.controller.logging.bridge.internal;
+
+import org.osgi.service.log.LogEntry;
+import java.util.Enumeration;
+import org.osgi.framework.BundleContext;
+import org.osgi.framework.BundleActivator;
+import org.osgi.framework.ServiceRegistration;
+import org.osgi.framework.ServiceReference;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.slf4j.ILoggerFactory;
+import org.osgi.service.log.LogReaderService;
+
+public class Activator implements BundleActivator {
+    private LogListenerImpl listener = null;
+    private Logger log = null;
+
+    @Override
+    public void start(BundleContext context) {
+        // Lets trigger the resolution of the slf4j logger factory
+        ILoggerFactory f = LoggerFactory.getILoggerFactory();
+
+        // Now retrieve a logger for the bridge
+        log = f
+                .getLogger("org.opendaylight.controller.logging.bridge.OSGI2SLF4J");
+
+        if (this.log != null) {
+            this.listener = new LogListenerImpl(log);
+
+            ServiceReference service = null;
+            service = context.getServiceReference(LogReaderService.class
+                    .getName());
+            if (service != null) {
+                LogReaderService reader = (LogReaderService) context
+                        .getService(service);
+                if (reader == null) {
+                    this.log.error("Cannot register the LogListener because "
+                            + "cannot retrive LogReaderService");
+                }
+                reader.addLogListener(this.listener);
+                // Now lets walk all the exiting messages
+                Enumeration<LogEntry> entries = reader.getLog();
+                if (entries != null) {
+                    while (entries.hasMoreElements()) {
+                        LogEntry entry = (LogEntry) entries.nextElement();
+                        this.listener.logged(entry);
+                    }
+                }
+            } else {
+                this.log.error("Cannot register the LogListener because "
+                        + "cannot retrive LogReaderService");
+            }
+        } else {
+            System.err
+                    .println("Could not initialize the logging bridge subsytem");
+        }
+    }
+
+    @Override
+    public void stop(BundleContext context) {
+        ServiceReference service = null;
+        service = context.getServiceReference(LogReaderService.class.getName());
+        if (service != null) {
+            LogReaderService reader = (LogReaderService) service;
+            reader.removeLogListener(this.listener);
+        }
+
+        this.listener = null;
+        this.log = null;
+    }
+}