pekko/akka-fun-test-java/src/test/java/se/scalablesolutions/akka/api/PersistentStateful.java

package se.scalablesolutions.akka.api;

import se.scalablesolutions.akka.annotation.inittransactionalstate;
import se.scalablesolutions.akka.annotation.transactionrequired;
import se.scalablesolutions.akka.state.*;

@transactionrequired
public class PersistentStateful {
  private PersistentMap mapState;
  private PersistentVector vectorState;
  private PersistentRef refState;

  @inittransactionalstate
  public void init() {
    mapState = PersistentState.newMap(new CassandraStorageConfig());
    vectorState = PersistentState.newVector(new CassandraStorageConfig());
    refState = PersistentState.newRef(new CassandraStorageConfig());
  }
 
  public String getMapState(String key) {
    return (String) mapState.get(key).get();
  }

  
  public String getVectorState(int index) {
    return (String) vectorState.get(index);
  }

  public int getVectorLength() {
    return vectorState.length();
  }

  public String getRefState() {
    if (refState.isDefined()) {
      return (String) refState.get().get();
    } else throw new IllegalStateException("No such element");
  }

  
  public void setMapState(String key, String msg) {
    mapState.put(key, msg);
  }

  
  public void setVectorState(String msg) {
    vectorState.add(msg);
  }

  
  public void setRefState(String msg) {
    refState.swap(msg);
  }

  
  public void success(String key, String msg) {
    mapState.put(key, msg);
    vectorState.add(msg);
    refState.swap(msg);
  }

  
  public String failure(String key, String msg, PersistentFailer failer) {
    mapState.put(key, msg);
    vectorState.add(msg);
    refState.swap(msg);
    failer.fail();
    return msg;
  }

  public String success(String key, String msg, PersistentStatefulNested nested) {
    mapState.put(key, msg);
    vectorState.add(msg);
    refState.swap(msg);
    nested.success(key, msg);
    return msg;
  }

  
  public String failure(String key, String msg, PersistentStatefulNested nested, PersistentFailer failer) {
    mapState.put(key, msg);
    vectorState.add(msg);
    refState.swap(msg);
    nested.failure(key, msg, failer);
    return msg;
  }


  
  public void thisMethodHangs(String key, String msg, PersistentFailer failer) {
    setMapState(key, msg);
  }
}