summaryrefslogtreecommitdiff
path: root/domain
diff options
context:
space:
mode:
authorMike Vink <mike1994vink@gmail.com>2021-07-27 17:00:00 +0200
committerMike Vink <mike1994vink@gmail.com>2021-07-27 17:00:00 +0200
commit019ea5fcefa16c2746fb2c7d6fa4a29d18b8d53b (patch)
tree417922906da5993f059d2c695887f029711b9878 /domain
parent79a9fb88a9dd43caddaa011ce2dd920a2caefd85 (diff)
tmp(): preparation for battle starting
Diffstat (limited to 'domain')
-rw-r--r--domain/src/main/java/akkamon/domain/AkkamonNexus.java16
-rw-r--r--domain/src/main/java/akkamon/domain/HeartBeatQuery.java3
-rw-r--r--domain/src/main/java/akkamon/domain/Trainer.java6
3 files changed, 12 insertions, 13 deletions
diff --git a/domain/src/main/java/akkamon/domain/AkkamonNexus.java b/domain/src/main/java/akkamon/domain/AkkamonNexus.java
index d467df7..4958e21 100644
--- a/domain/src/main/java/akkamon/domain/AkkamonNexus.java
+++ b/domain/src/main/java/akkamon/domain/AkkamonNexus.java
@@ -245,13 +245,13 @@ public class AkkamonNexus extends AbstractBehavior<AkkamonNexus.Command> {
// Turn on for logging
- StringBuilder positions = new StringBuilder();
- positions.append("\n" + response.sceneId.toUpperCase(Locale.ROOT) + "\n");
- for (Map.Entry<String, MovementQueueReading> entry : response.trainerMovementQueues.entrySet()) {
- positions.append(entry.getKey() + ": " +entry.getValue());
- positions.append("\n");
- }
- getContext().getLog().info(String.valueOf(positions));
+ // StringBuilder positions = new StringBuilder();
+ // positions.append("\n" + response.sceneId.toUpperCase(Locale.ROOT) + "\n");
+ // for (Map.Entry<String, MovementQueueReading> entry : response.trainerMovementQueues.entrySet()) {
+ // positions.append(entry.getKey() + ": " +entry.getValue());
+ // positions.append("\n");
+ // }
+ // getContext().getLog().info(String.valueOf(positions));
messageEngine.broadCastHeartBeatToScene(response.sceneId, response.trainerMovementQueues);
@@ -305,8 +305,8 @@ public class AkkamonNexus extends AbstractBehavior<AkkamonNexus.Command> {
private AkkamonNexus onTrainerRegistered(TrainerRegistered reply) {
// TODO test when registration fails?
getContext().getLog().info("Adding {} to scene {} Live AkkamonSessions in Messaging Engine", reply.trainerId, reply.sceneId);
- messageEngine.registerTrainerSessionToScene(reply.sceneId, reply.session);
reply.session.setTrainerId(reply.trainerId);
+ messageEngine.registerTrainerSessionToScene(reply.sceneId, reply.session);
return this;
}
diff --git a/domain/src/main/java/akkamon/domain/HeartBeatQuery.java b/domain/src/main/java/akkamon/domain/HeartBeatQuery.java
index 5e88ff5..aa201c3 100644
--- a/domain/src/main/java/akkamon/domain/HeartBeatQuery.java
+++ b/domain/src/main/java/akkamon/domain/HeartBeatQuery.java
@@ -86,8 +86,7 @@ public class HeartBeatQuery extends AbstractBehavior<HeartBeatQuery.Command> {
new Trainer.ReadMovementQueue(
0L,
respondTrainerPositionAdapter
- )
- );
+ ));
}
stillWaiting = new HashSet<>(trainerIdToActor.keySet());
}
diff --git a/domain/src/main/java/akkamon/domain/Trainer.java b/domain/src/main/java/akkamon/domain/Trainer.java
index 710f844..caad860 100644
--- a/domain/src/main/java/akkamon/domain/Trainer.java
+++ b/domain/src/main/java/akkamon/domain/Trainer.java
@@ -101,7 +101,7 @@ public class Trainer extends AbstractBehavior<Trainer.Command> {
}
private Trainer onNewTilePos(AkkamonNexus.RequestNewTilePos newTilePosRequest) {
- getContext().getLog().info("Trainer {} has new {}.", trainerId, newTilePosRequest.tilePos);
+ // getContext().getLog().info("Trainer {} has new {}.", trainerId, newTilePosRequest.tilePos);
if (isMoving()) {
this.movementQueue.add(this.movementDirection);
}
@@ -109,13 +109,13 @@ public class Trainer extends AbstractBehavior<Trainer.Command> {
}
private Trainer onStopMoving(AkkamonNexus.RequestStopMoving stopMovingRequest) {
- getContext().getLog().info("Trainer {} stops to move {}.", trainerId, stopMovingRequest.direction);
+ // getContext().getLog().info("Trainer {} stops to move {}.", trainerId, stopMovingRequest.direction);
this.movementDirection = Direction.NONE;
return this;
}
private Trainer onStartMoving(AkkamonNexus.RequestStartMoving startMovingRequest) {
- getContext().getLog().info("Trainer {} starts to move {}.", trainerId, startMovingRequest.direction);
+ // getContext().getLog().info("Trainer {} starts to move {}.", trainerId, startMovingRequest.direction);
this.movementDirection = startMovingRequest.direction;
return this;
}