Embedded OSGi Apache Felix
This commit is contained in:
74
pom.xml
Normal file
74
pom.xml
Normal file
@@ -0,0 +1,74 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
|
||||
xmlns="http://maven.apache.org/POM/4.0.0"
|
||||
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
|
||||
http://maven.apache.org/xsd/maven-4.0.0.xsd">
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
<name>ASys Core</name>
|
||||
|
||||
<groupId>asys</groupId>
|
||||
<artifactId>asys-core</artifactId>
|
||||
<packaging>jar</packaging>
|
||||
<version>0.0-SNAPSHOT</version>
|
||||
|
||||
<developers>
|
||||
<developer>
|
||||
<name>DmitriyMX</name>
|
||||
<email>dimon550@gmail.com</email>
|
||||
</developer>
|
||||
</developers>
|
||||
|
||||
<properties>
|
||||
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
|
||||
<java.version>1.8</java.version>
|
||||
<slf4j.version>1.7.21</slf4j.version>
|
||||
</properties>
|
||||
|
||||
<dependencies>
|
||||
<dependency>
|
||||
<groupId>org.slf4j</groupId>
|
||||
<artifactId>slf4j-api</artifactId>
|
||||
<version>${slf4j.version}</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.slf4j</groupId>
|
||||
<artifactId>slf4j-simple</artifactId>
|
||||
<version>${slf4j.version}</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.apache.felix</groupId>
|
||||
<artifactId>org.apache.felix.framework</artifactId>
|
||||
<version>5.6.1</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>com.google.guava</groupId>
|
||||
<artifactId>guava</artifactId>
|
||||
<version>21.0</version>
|
||||
</dependency>
|
||||
</dependencies>
|
||||
|
||||
<build>
|
||||
<finalName>${project.artifactId}-${project.version}</finalName>
|
||||
<plugins>
|
||||
<plugin>
|
||||
<groupId>org.apache.maven.plugins</groupId>
|
||||
<artifactId>maven-compiler-plugin</artifactId>
|
||||
<version>3.5.1</version>
|
||||
<configuration>
|
||||
<source>${java.version}</source>
|
||||
<target>${java.version}</target>
|
||||
<encoding>${project.build.sourceEncoding}</encoding>
|
||||
</configuration>
|
||||
</plugin>
|
||||
<plugin>
|
||||
<groupId>org.apache.maven.plugins</groupId>
|
||||
<artifactId>maven-surefire-plugin</artifactId>
|
||||
<version>2.15</version>
|
||||
<configuration>
|
||||
<argLine>-Dfile.encoding=${project.build.sourceEncoding}</argLine>
|
||||
</configuration>
|
||||
</plugin>
|
||||
</plugins>
|
||||
</build>
|
||||
</project>
|
||||
75
src/main/java/asys/core/Core.java
Normal file
75
src/main/java/asys/core/Core.java
Normal file
@@ -0,0 +1,75 @@
|
||||
/*
|
||||
* DmitriyMX <dimon550@gmail.com>
|
||||
* 2017-03-02
|
||||
*/
|
||||
package asys.core;
|
||||
|
||||
import org.apache.felix.framework.Felix;
|
||||
import org.apache.felix.framework.util.ImmutableList;
|
||||
import org.apache.felix.framework.util.ImmutableMap;
|
||||
import org.osgi.framework.BundleActivator;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
import javax.annotation.PostConstruct;
|
||||
import javax.annotation.PreDestroy;
|
||||
import java.util.ArrayList;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
import static org.apache.felix.framework.util.FelixConstants.SYSTEMBUNDLE_ACTIVATORS_PROP;
|
||||
|
||||
public class Core {
|
||||
private final Logger logger = LoggerFactory.getLogger(this.getClass());
|
||||
private Felix felix;
|
||||
private BundleActivator hostActivator;
|
||||
|
||||
public Core() {
|
||||
logger.trace("core created");
|
||||
}
|
||||
|
||||
@PostConstruct
|
||||
public void start() {
|
||||
hostActivator = new HostActivator();
|
||||
startFelix();
|
||||
}
|
||||
|
||||
private void startFelix() {
|
||||
logger.trace("starting Apache Felix (OSGi)");
|
||||
|
||||
try {
|
||||
felix = new Felix(createFelixConfig());
|
||||
felix.start();
|
||||
} catch (Exception e) {
|
||||
throw new RuntimeException(e);
|
||||
}
|
||||
}
|
||||
|
||||
private Map<String, Object> createFelixConfig() {
|
||||
Map<String, Object> config = new HashMap<>();
|
||||
|
||||
config.put(SYSTEMBUNDLE_ACTIVATORS_PROP, ImmutableList.newInstance(this.hostActivator));
|
||||
config.put("felix.fileinstall.poll", 250);
|
||||
config.put("felix.fileinstall.log.level", 2);
|
||||
config.put("felix.fileinstall.noInitialDelay", true);
|
||||
|
||||
return ImmutableMap.newInstance(config);
|
||||
}
|
||||
|
||||
@PreDestroy
|
||||
public void stop() {
|
||||
startFelix();
|
||||
}
|
||||
|
||||
private void stopFelix() {
|
||||
logger.trace("shutdown Apache Felix (OSGi)");
|
||||
|
||||
try {
|
||||
felix.stop();
|
||||
felix.waitForStop(5000L);
|
||||
} catch (Exception e) {
|
||||
logger.error("Error shutdown Felix", e);
|
||||
}
|
||||
}
|
||||
}
|
||||
24
src/main/java/asys/core/HostActivator.java
Normal file
24
src/main/java/asys/core/HostActivator.java
Normal file
@@ -0,0 +1,24 @@
|
||||
/*
|
||||
* DmitriyMX <dimon550@gmail.com>
|
||||
* 2017-03-02
|
||||
*/
|
||||
package asys.core;
|
||||
|
||||
import org.osgi.framework.BundleActivator;
|
||||
import org.osgi.framework.BundleContext;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
public class HostActivator implements BundleActivator {
|
||||
private final Logger logger = LoggerFactory.getLogger(this.getClass());
|
||||
|
||||
@Override
|
||||
public void start(BundleContext bundleContext) throws Exception {
|
||||
logger.trace("call [HostActivator.start(BundleContext)]");
|
||||
}
|
||||
|
||||
@Override
|
||||
public void stop(BundleContext bundleContext) throws Exception {
|
||||
logger.trace("call [HostActivator.stop(BundleContext)]");
|
||||
}
|
||||
}
|
||||
12
src/main/java/asys/core/Main.java
Normal file
12
src/main/java/asys/core/Main.java
Normal file
@@ -0,0 +1,12 @@
|
||||
/*
|
||||
* DmitriyMX <dimon550@gmail.com>
|
||||
* 2017-03-02
|
||||
*/
|
||||
package asys.core;
|
||||
|
||||
public class Main {
|
||||
public static void main(String[] args) {
|
||||
Core asysCore = new Core();
|
||||
asysCore.start();
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user