You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@karaf.apache.org by jb...@apache.org on 2015/02/04 17:36:12 UTC
[28/30] karaf-decanter git commit: Register OSGi service for the
Elasticsearch node
Register OSGi service for the Elasticsearch node
Project: http://git-wip-us.apache.org/repos/asf/karaf-decanter/repo
Commit: http://git-wip-us.apache.org/repos/asf/karaf-decanter/commit/16ea3797
Tree: http://git-wip-us.apache.org/repos/asf/karaf-decanter/tree/16ea3797
Diff: http://git-wip-us.apache.org/repos/asf/karaf-decanter/diff/16ea3797
Branch: refs/heads/master
Commit: 16ea3797ec6269f4a148c5b055f9d1d6351a8ece
Parents: 7560f65
Author: Jean-Baptiste Onofré <jb...@apache.org>
Authored: Wed Oct 15 11:13:54 2014 +0200
Committer: Jean-Baptiste Onofré <jb...@apache.org>
Committed: Wed Oct 15 11:13:54 2014 +0200
----------------------------------------------------------------------
.../org/apache/karaf/decanter/elasticsearch/Activator.java | 7 +++++++
.../org/apache/karaf/decanter/elasticsearch/EmbeddedNode.java | 4 ++++
2 files changed, 11 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/karaf-decanter/blob/16ea3797/elasticsearch/src/main/java/org/apache/karaf/decanter/elasticsearch/Activator.java
----------------------------------------------------------------------
diff --git a/elasticsearch/src/main/java/org/apache/karaf/decanter/elasticsearch/Activator.java b/elasticsearch/src/main/java/org/apache/karaf/decanter/elasticsearch/Activator.java
index 2a55d6a..ed4ae5f 100644
--- a/elasticsearch/src/main/java/org/apache/karaf/decanter/elasticsearch/Activator.java
+++ b/elasticsearch/src/main/java/org/apache/karaf/decanter/elasticsearch/Activator.java
@@ -16,17 +16,21 @@
*/
package org.apache.karaf.decanter.elasticsearch;
+import org.elasticsearch.node.Node;
import org.osgi.framework.BundleActivator;
import org.osgi.framework.BundleContext;
+import org.osgi.framework.ServiceRegistration;
public class Activator implements BundleActivator {
private EmbeddedNode node;
+ private ServiceRegistration service;
public void start(BundleContext bundleContext) throws Exception {
if (node == null) {
node = new EmbeddedNode();
}
+ service = bundleContext.registerService(Node.class, node.getNode(), null);
node.start();
}
@@ -34,6 +38,9 @@ public class Activator implements BundleActivator {
if (node != null) {
node.stop();
}
+ if (service != null) {
+ service.unregister();
+ }
}
}
http://git-wip-us.apache.org/repos/asf/karaf-decanter/blob/16ea3797/elasticsearch/src/main/java/org/apache/karaf/decanter/elasticsearch/EmbeddedNode.java
----------------------------------------------------------------------
diff --git a/elasticsearch/src/main/java/org/apache/karaf/decanter/elasticsearch/EmbeddedNode.java b/elasticsearch/src/main/java/org/apache/karaf/decanter/elasticsearch/EmbeddedNode.java
index 5e7ad26..6eb1be9 100644
--- a/elasticsearch/src/main/java/org/apache/karaf/decanter/elasticsearch/EmbeddedNode.java
+++ b/elasticsearch/src/main/java/org/apache/karaf/decanter/elasticsearch/EmbeddedNode.java
@@ -87,4 +87,8 @@ public class EmbeddedNode {
return false;
}
+ public Node getNode() {
+ return node;
+ }
+
}