diff --git a/backend/.gitignore b/backend/.gitignore new file mode 100644 index 0000000..89540d8 --- /dev/null +++ b/backend/.gitignore @@ -0,0 +1 @@ +/dependency-reduced-pom.xml diff --git a/backend/pom.xml b/backend/pom.xml index baf18a2..4d71278 100644 --- a/backend/pom.xml +++ b/backend/pom.xml @@ -49,4 +49,31 @@ + + + + + + org.apache.maven.plugins + maven-shade-plugin + 3.5.3 + + + package + + shade + + + false + + + net.miarma.contaminus.server.MainVerticle + + + + + + + + \ No newline at end of file diff --git a/backend/src/main/java/net/miarma/contaminus/clase/BroadcastVerticle.java b/backend/src/main/java/net/miarma/contaminus/clase/BroadcastVerticle.java deleted file mode 100644 index 4faccb2..0000000 --- a/backend/src/main/java/net/miarma/contaminus/clase/BroadcastVerticle.java +++ /dev/null @@ -1,18 +0,0 @@ -package net.miarma.contaminus.clase; - -import io.vertx.core.AbstractVerticle; -import io.vertx.core.Promise; - -public class BroadcastVerticle extends AbstractVerticle { - @Override - public void start(Promise promise) { - vertx.setPeriodic(2000, _a -> { - vertx.eventBus().publish("broadcast.addr", "Ola"); - }); - try { - promise.complete(); - } catch (Exception e) { - promise.fail(e); - } - } -} diff --git a/backend/src/main/java/net/miarma/contaminus/clase/ConsumerVerticle1.java b/backend/src/main/java/net/miarma/contaminus/clase/ConsumerVerticle1.java deleted file mode 100644 index 23cf86f..0000000 --- a/backend/src/main/java/net/miarma/contaminus/clase/ConsumerVerticle1.java +++ /dev/null @@ -1,23 +0,0 @@ -package net.miarma.contaminus.clase; - -import io.vertx.core.AbstractVerticle; -import io.vertx.core.Promise; -import io.vertx.core.eventbus.Message; -import net.miarma.contaminus.common.Constants; - -public class ConsumerVerticle1 extends AbstractVerticle { - @Override - public void start(Promise promise) { - vertx.eventBus().consumer("broadcast.addr", this::handleMsg); - try { - promise.complete(); - } catch (Exception e) { - promise.fail(e); - } - } - - private void handleMsg(Message msg) { - Constants.LOGGER.info("Ola Broadcast soy Consumer1"); - } - -} diff --git a/backend/src/main/java/net/miarma/contaminus/clase/ConsumerVerticle2.java b/backend/src/main/java/net/miarma/contaminus/clase/ConsumerVerticle2.java deleted file mode 100644 index 3bb2938..0000000 --- a/backend/src/main/java/net/miarma/contaminus/clase/ConsumerVerticle2.java +++ /dev/null @@ -1,23 +0,0 @@ -package net.miarma.contaminus.clase; - -import io.vertx.core.AbstractVerticle; -import io.vertx.core.Promise; -import io.vertx.core.eventbus.Message; -import net.miarma.contaminus.common.Constants; - -public class ConsumerVerticle2 extends AbstractVerticle { - @Override - public void start(Promise promise) { - vertx.eventBus().consumer("broadcast.addr", this::handleMsg); - try { - promise.complete(); - } catch (Exception e) { - promise.fail(e); - } - } - - private void handleMsg(Message msg) { - Constants.LOGGER.info("Ola Broadcast soy Consumer2"); - } - -} diff --git a/backend/src/main/java/net/miarma/contaminus/clase/MainVerticleClase.java b/backend/src/main/java/net/miarma/contaminus/clase/MainVerticleClase.java deleted file mode 100644 index b83d2d8..0000000 --- a/backend/src/main/java/net/miarma/contaminus/clase/MainVerticleClase.java +++ /dev/null @@ -1,32 +0,0 @@ -package net.miarma.contaminus.clase; - -import io.vertx.core.AbstractVerticle; -import io.vertx.core.Promise; -import net.miarma.contaminus.common.Constants; - -public class MainVerticleClase extends AbstractVerticle { - @Override - public void start(Promise promise) { - vertx.deployVerticle(new BroadcastVerticle(), result -> { - if(result.succeeded()) { - Constants.LOGGER.info("📡 BroadcastVerticle desplegado"); - } else { - Constants.LOGGER.error("❌ Error al desplegar BroadcastVerticle", result.cause()); - } - }); - vertx.deployVerticle(new ConsumerVerticle1(), result -> { - if(result.succeeded()) { - Constants.LOGGER.info("📡 ConsumerVerticle1 desplegado"); - } else { - Constants.LOGGER.error("❌ Error al desplegar ConsumerVerticle1", result.cause()); - } - }); - vertx.deployVerticle(new ConsumerVerticle2(), result -> { - if(result.succeeded()) { - Constants.LOGGER.info("📡 ConsumerVerticle2 desplegado"); - } else { - Constants.LOGGER.error("❌ Error al desplegar ConsumerVerticle2", result.cause()); - } - }); - } -} diff --git a/backend/src/main/java/net/miarma/contaminus/server/MainVerticle.java b/backend/src/main/java/net/miarma/contaminus/server/MainVerticle.java index e57eb7a..ed96d17 100644 --- a/backend/src/main/java/net/miarma/contaminus/server/MainVerticle.java +++ b/backend/src/main/java/net/miarma/contaminus/server/MainVerticle.java @@ -23,4 +23,8 @@ public class MainVerticle extends AbstractVerticle { .forEach(v -> getVertx().undeploy(v)); } + public static void main(String[] args) { + io.vertx.core.Launcher.executeCommand("run", MainVerticle.class.getName()); + } + } \ No newline at end of file