diff --git a/modules/telestion-application/src/main/java/org/telestion/application/RocketSound.java b/modules/telestion-application/src/main/java/org/telestion/application/RocketSound.java index b3627804..d439e803 100644 --- a/modules/telestion-application/src/main/java/org/telestion/application/RocketSound.java +++ b/modules/telestion-application/src/main/java/org/telestion/application/RocketSound.java @@ -40,12 +40,12 @@ public static void main(String[] args) { new MongoDatabaseService("raketenpraktikum", "raketenpraktikumPool"), new DataService(dataTypeMap, Collections.emptyMap()) );*/ - new DataService(Collections.emptyMap()), + /*new DataService(Collections.emptyMap()), new DataListener( List.of( Address.outgoing(MockRocketPublisher.class, "pub") ) ) - ); + );*/ } } diff --git a/modules/telestion-core/src/main/java/org/telestion/core/database/DataListener.java b/modules/telestion-core/src/main/java/org/telestion/core/database/DataListener.java index 9ece59bf..6b67ed19 100644 --- a/modules/telestion-core/src/main/java/org/telestion/core/database/DataListener.java +++ b/modules/telestion-core/src/main/java/org/telestion/core/database/DataListener.java @@ -8,7 +8,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.telestion.api.message.JsonMessage; -import org.telestion.core.config.Config; +import org.telestion.api.config.Config; import org.telestion.core.message.Address; public final class DataListener extends AbstractVerticle { diff --git a/modules/telestion-core/src/main/java/org/telestion/core/util/Offset.java b/modules/telestion-core/src/main/java/org/telestion/core/util/Offset.java deleted file mode 100644 index 0803cf9e..00000000 --- a/modules/telestion-core/src/main/java/org/telestion/core/util/Offset.java +++ /dev/null @@ -1,46 +0,0 @@ -package org.telestion.core.util; - -import io.vertx.core.AbstractVerticle; -import io.vertx.core.AsyncResult; -import io.vertx.core.Handler; -import io.vertx.core.Promise; -import io.vertx.core.json.JsonObject; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; -import org.telestion.api.message.JsonMessage; -import org.telestion.core.message.Address; -import org.telestion.core.message.DataOperation; - -public final class Offset extends AbstractVerticle { - private final Logger logger = LoggerFactory.getLogger(Offset.class); - - private final String inOffset = Address.incoming(Offset.class); - - public Offset() {} - - @Override - public void start(Promise startPromise) throws Exception { - this.registerConsumers(); - startPromise.complete(); - } - - private void registerConsumers() { - vertx.eventBus().consumer(inOffset, request -> { - JsonMessage.on(DataOperation.class, request, dataOperation -> { - this.calculateOffset(dataOperation, res -> { - if (res.failed()) { - request.fail(-1, res.cause().getMessage()); - } else { - request.reply(res.result()); - } - }); - }); - }); - } - - private void calculateOffset(DataOperation dataOperation, Handler> handler) { - // TODO: parse data of dOp to numeric value - // TODO: parse offset of dOp to numeric value - // TODO: add offset to data and return - } -}