diff --git a/ros3rag.placeA/src/main/java/de/tudresden/inf/st/placeA/MainA.java b/ros3rag.placeA/src/main/java/de/tudresden/inf/st/placeA/MainA.java index f39a4fd9bdcb954d005a61059afd11960828d073..157de87d3bbaed53de0fb47e66df021cc2ef3d02 100644 --- a/ros3rag.placeA/src/main/java/de/tudresden/inf/st/placeA/MainA.java +++ b/ros3rag.placeA/src/main/java/de/tudresden/inf/st/placeA/MainA.java @@ -23,6 +23,7 @@ public class MainA extends SharedMainParts<MqttHandler, WorldModelA> { private final String TOPIC_DEMO_MOVE_objectRed1_BLUE; private final String TOPIC_DEMO_MOVE_objectRed1_RED; + private final String TOPIC_EVAL_MOVE; MainA(String configFile) { super("place-a", UtilA.pathToDirectoryOfPlaceA().resolve(configFile)); @@ -31,6 +32,7 @@ public class MainA extends SharedMainParts<MqttHandler, WorldModelA> { this.TOPIC_DEMO_MOVE_objectRed1_BLUE = cellName + "/demo/move/objectRed1/blue"; this.TOPIC_DEMO_MOVE_objectRed1_RED = cellName + "/demo/move/objectRed1/red"; + this.TOPIC_EVAL_MOVE = cellName + "/eval/move"; } public static void main(String[] args) throws Exception { @@ -46,6 +48,12 @@ public class MainA extends SharedMainParts<MqttHandler, WorldModelA> { mainHandler.newConnection(TOPIC_DEMO_MOVE_objectRed1_RED, bytes -> UtilA.updatePositionOfObjectToLocation(model.getScene(), "objectRed1", "binRed") ); + mainHandler.newConnection(TOPIC_EVAL_MOVE, bytes -> { + String[] tokens = new String(bytes).split(" to "); + String objectName = tokens[0]; + String locationName = tokens[1]; + UtilA.updatePositionOfObjectToLocation(model.getScene(), objectName, locationName); + }); } @Override