diff options
| author | Mike Vink <mike1994vink@gmail.com> | 2021-07-27 17:00:00 +0200 |
|---|---|---|
| committer | Mike Vink <mike1994vink@gmail.com> | 2021-07-27 17:00:00 +0200 |
| commit | 019ea5fcefa16c2746fb2c7d6fa4a29d18b8d53b (patch) | |
| tree | 417922906da5993f059d2c695887f029711b9878 /domain | |
| parent | 79a9fb88a9dd43caddaa011ce2dd920a2caefd85 (diff) | |
tmp(): preparation for battle starting
Diffstat (limited to 'domain')
| -rw-r--r-- | domain/src/main/java/akkamon/domain/AkkamonNexus.java | 16 | ||||
| -rw-r--r-- | domain/src/main/java/akkamon/domain/HeartBeatQuery.java | 3 | ||||
| -rw-r--r-- | domain/src/main/java/akkamon/domain/Trainer.java | 6 |
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; } |
