bogdan-dumitrescu

This app is provided as-is, without warranties of any kind. Groove Trainer does not store or process any data about its users. 
The underlying grooves & rudiments database is kept up-to-date by means of an anonymous web service.

bogdan-dumitrescu

@Actor(stateClass = SampleState.class, serializationFramework = JacksonSerializationFramework.class)
@PersistenceConfig(persistOnMessages = true, excluded = PositionsRequest.class)
public class SampleActor extends MethodActor

bogdan-dumitrescu

import org.elasticsoftware.elasticactors.Actor;
import org.elasticsoftware.elasticactors.ActorRef;
import org.elasticsoftware.elasticactors.MessageHandler;
import org.elasticsoftware.elasticactors.MethodActor;
import org.elasticsoftware.elasticactors.base.serialization.JacksonSerializationFramework;

@Actor(stateClass = SampleState.class, serializationFramework = JacksonSerializationFramework.class)
public class SampleActor extends MethodActor {

    @MessageHandler

bogdan-dumitrescu

import org.elasticsoftware.elasticactors.ActorRef;
import org.elasticsoftware.elasticactors.ActorSystem;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;
import reactor.core.publisher.Mono;

@RestController
public class SampleController {

bogdan-dumitrescu

import org.elasticsoftware.elasticactors.base.serialization.JacksonSerializationFramework;
import org.elasticsoftware.elasticactors.serialization.Message;

@Message(serializationFramework = JacksonSerializationFramework.class)
public class AddPosition {

    private final Position position;
    
    public AddPosition(Position position) {
        this.position = position;

bogdan-dumitrescu

import org.elasticsoftware.elasticactors.Actor;
import org.elasticsoftware.elasticactors.ActorRef;
import org.elasticsoftware.elasticactors.MessageHandler;
import org.elasticsoftware.elasticactors.MethodActor;
import org.elasticsoftware.elasticactors.base.serialization.JacksonSerializationFramework;

@Actor(stateClass = SampleState.class, serializationFramework = JacksonSerializationFramework.class)
public class SampleActor extends MethodActor {

    @MessageHandler

bogdan-dumitrescu

import org.elasticsoftware.elasticactors.Actor;
import org.elasticsoftware.elasticactors.ActorRef;
import org.elasticsoftware.elasticactors.MethodActor;
import org.elasticsoftware.elasticactors.base.serialization.JacksonSerializationFramework;

@Actor(stateClass = SampleState.class, serializationFramework = JacksonSerializationFramework.class)
public class SampleActor extends MethodActor {

    @Override
    public void onReceive(ActorRef sender, Object message) throws Exception {

bogdan-dumitrescu

import org.elasticsoftware.elasticactors.base.serialization.JacksonSerializationFramework;
import org.elasticsoftware.elasticactors.serialization.Message;

import java.util.List;

@Message(serializationFramework = JacksonSerializationFramework.class)
public class PositionsResponse {

    private final List<Position> positions;

bogdan-dumitrescu

import org.elasticsoftware.elasticactors.base.serialization.JacksonSerializationFramework;
import org.elasticsoftware.elasticactors.serialization.Message;

@Message(serializationFramework = JacksonSerializationFramework.class)
public class PositionsRequest {
}

bogdan-dumitrescu

import org.elasticsoftware.elasticactors.ActorRef;
import org.elasticsoftware.elasticactors.ActorSystem;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;
import reactor.core.publisher.Mono;

@RestController
public class SampleController {