65 lines
2.5 KiB
Java
65 lines
2.5 KiB
Java
|
package com.example;
|
||
|
|
|
||
|
|
import akka.actor.typed.ActorRef;
|
||
|
|
import akka.actor.typed.Behavior;
|
||
|
|
import akka.actor.typed.javadsl.AbstractBehavior;
|
||
|
|
import akka.actor.typed.javadsl.ActorContext;
|
||
|
|
import akka.actor.typed.javadsl.Behaviors;
|
||
|
|
import akka.actor.typed.javadsl.Receive;
|
||
|
|
|
||
|
|
public class PrintAndEvaluate extends AbstractBehavior<PrintAndEvaluate.Message> {
|
||
|
|
|
||
|
|
String name;
|
||
|
|
public interface Message{}
|
||
|
|
|
||
|
|
public record StringResponse(String string) implements Message{}
|
||
|
|
|
||
|
|
public record StartMessage(Expression expression) implements Message{}
|
||
|
|
|
||
|
|
public record IntResponse(int wert) implements Message{}
|
||
|
|
|
||
|
|
private PrintAndEvaluate(ActorContext<PrintAndEvaluate.Message> context, String name){
|
||
|
|
super(context);
|
||
|
|
this.name = name;
|
||
|
|
}
|
||
|
|
|
||
|
|
public static Behavior<PrintAndEvaluate.Message> create(String name){
|
||
|
|
return Behaviors.setup(context -> new PrintAndEvaluate(context, name));
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override
|
||
|
|
public Receive<PrintAndEvaluate.Message> createReceive(){
|
||
|
|
return newReceiveBuilder()
|
||
|
|
.onMessage(StartMessage.class, this::onStartMessage)
|
||
|
|
.onMessage(StringResponse.class, this::onStringResponse)
|
||
|
|
.onMessage(IntResponse.class, this::onIntResponse)
|
||
|
|
.build();
|
||
|
|
}
|
||
|
|
|
||
|
|
//Mit dieser Message wird der PrintAndEvaluate Aktor in Gang gesetzt
|
||
|
|
private Behavior<Message> onStartMessage(StartMessage message){
|
||
|
|
//Starten des Formatierungsvorganges
|
||
|
|
this.getContext().getLog().info("\n Beginn der Ausdrucksformatierung");
|
||
|
|
ActorRef<Actor.Message> printActor = getContext().spawnAnonymous(Actor.create());
|
||
|
|
printActor.tell(new Actor.PrintMessage(getContext().getSelf(),message.expression));
|
||
|
|
|
||
|
|
//Starten des Berechnungsvorganges
|
||
|
|
this.getContext().getLog().info("\n Beginn der Berechnung");
|
||
|
|
ActorRef<Actor.Message> computeActor = getContext().spawnAnonymous(Actor.create());
|
||
|
|
computeActor.tell(new Actor.EvaluateMessage(getContext().getSelf(), message.expression));
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
//Ausgeben des Ausdruckes als String
|
||
|
|
private Behavior<Message> onStringResponse(StringResponse response){
|
||
|
|
this.getContext().getLog().info("\n Formatierter Ausdruck: " + response.string);
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
//Ausgeben des berechneten Wertes von dem Ausdruck
|
||
|
|
private Behavior<Message> onIntResponse(IntResponse response){
|
||
|
|
this.getContext().getLog().info("\n Ausgerechneter Wert: " + response.wert);
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
}
|