NoIssue: Auto start en dummy app
This commit is contained in:
16
src/main/java/com/r35157/nenjim/kicker/impl/ref/Dummy.java
Normal file
16
src/main/java/com/r35157/nenjim/kicker/impl/ref/Dummy.java
Normal file
@@ -0,0 +1,16 @@
|
|||||||
|
package com.r35157.nenjim.kicker.impl.ref;
|
||||||
|
|
||||||
|
import com.r35157.nenjim.kicker.NenjimProcess;
|
||||||
|
import org.jetbrains.annotations.NotNull;
|
||||||
|
|
||||||
|
public class Dummy implements NenjimProcess {
|
||||||
|
@Override
|
||||||
|
public void run() {
|
||||||
|
System.out.println("Hello! This is '" + getName() + "'");
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public @NotNull String getName() {
|
||||||
|
return "Just A Dummy";
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -13,6 +13,14 @@ import java.util.concurrent.atomic.AtomicInteger;
|
|||||||
|
|
||||||
public class KickerImpl implements Kicker {
|
public class KickerImpl implements Kicker {
|
||||||
|
|
||||||
|
static void main() {
|
||||||
|
new KickerImpl();
|
||||||
|
}
|
||||||
|
|
||||||
|
public KickerImpl() {
|
||||||
|
startProcess("com.r35157.nenjim.kicker.impl.ref.Dummy");
|
||||||
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void startProcess(@NotNull String fqInterfaceName) {
|
public void startProcess(@NotNull String fqInterfaceName) {
|
||||||
ClassLoader loader = ClassLoader.getSystemClassLoader();
|
ClassLoader loader = ClassLoader.getSystemClassLoader();
|
||||||
@@ -41,12 +49,16 @@ public class KickerImpl implements Kicker {
|
|||||||
proc.setContext(context);
|
proc.setContext(context);
|
||||||
proc.setHub(null); log.warn("TODO: Set the HUB here when we have one!");
|
proc.setHub(null); log.warn("TODO: Set the HUB here when we have one!");
|
||||||
|
|
||||||
|
System.out.println("@@@1");
|
||||||
Thread t = Thread.ofVirtual()
|
Thread t = Thread.ofVirtual()
|
||||||
.name(procName)
|
.name(procName)
|
||||||
.start(() -> {
|
.start(() -> {
|
||||||
|
System.out.println("@@@2");
|
||||||
try {
|
try {
|
||||||
log.info("Starting process '{}' (#{})...", procName, processId);
|
log.info("Starting process '{}' (#{})...", procName, processId);
|
||||||
|
System.out.println("@@@3");
|
||||||
proc.run();
|
proc.run();
|
||||||
|
System.out.println("@@@4");
|
||||||
} catch (Throwable e) {
|
} catch (Throwable e) {
|
||||||
log.error("Process '{}' (#{}) crashed!", procName, processId, e);
|
log.error("Process '{}' (#{}) crashed!", procName, processId, e);
|
||||||
} finally {
|
} finally {
|
||||||
|
|||||||
Reference in New Issue
Block a user