Gallardo7761/contaminus
Archived
1
0
Fork 0
Code Pull Requests Activity

POM changes for jar building

Browse Source
This commit is contained in:
Jose
2025-03-12 02:16:29 +01:00
parent b36be73968
commit 7d592812de
7 changed files with 32 additions and 96 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
backend/src/main/java/net/miarma/contaminus/clase/BroadcastVerticle.java
View File

@@ -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<Void> promise) {
vertx.setPeriodic(2000, _a -> {
vertx.eventBus().publish("broadcast.addr", "Ola");
});
try {
promise.complete();
} catch (Exception e) {
promise.fail(e);
}
}
}

23
backend/src/main/java/net/miarma/contaminus/clase/ConsumerVerticle1.java
View File

@@ -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<Void> promise) {
vertx.eventBus().consumer("broadcast.addr", this::handleMsg);
try {
promise.complete();
} catch (Exception e) {
promise.fail(e);
}
}
private void handleMsg(Message<String> msg) {
Constants.LOGGER.info("Ola Broadcast soy Consumer1");
}
}

23
backend/src/main/java/net/miarma/contaminus/clase/ConsumerVerticle2.java
View File

@@ -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<Void> promise) {
vertx.eventBus().consumer("broadcast.addr", this::handleMsg);
try {
promise.complete();
} catch (Exception e) {
promise.fail(e);
}
}
private void handleMsg(Message<String> msg) {
Constants.LOGGER.info("Ola Broadcast soy Consumer2");
}
}

32
backend/src/main/java/net/miarma/contaminus/clase/MainVerticleClase.java
View File

@@ -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<Void> 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());
}
});
}
}

4
backend/src/main/java/net/miarma/contaminus/server/MainVerticle.java
View File

@@ -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());
}
}