Page History

final case class SnapshotMetadata(persistenceId: String, sequenceNr: Long, timestamp: Long = 0L)


@Component
@Scope("prototype")
public class SnapShotActor extends AbstractPersistentActor {
	
	private final LoggingAdapter log = Logging.getLogger(getContext().system(), "AbstractPersistentActor");	  		
	private Object state;
	private int snapShotInterval = 5;
	
    @Override
    public String persistenceId() { return "ExamplePersistentActor-id-1"; }
    
    @Override public Receive createReceiveRecover() {
	  return receiveBuilder().
	    = 1000;

match(SnapshotOffer.class, s -> {
	      state = s.snapshot();	//상태복원
	      // ...
	    }).
	    match(String.class, s -> {/* ...*/}).build();
	}
	 
	// 스냅샷을 지원하는 메시지 정의
	@Override public Receive createReceive() {
	  return receiveBuilder().
	    match(SaveSnapshotSuccess.class, ss -> {
	      SnapshotMetadata metadata = ss.metadata();
	      // ...
	    }).
	    match(SaveSnapshotFailure.class, sf -> {
	      SnapshotMetadata metadata = sf.metadata();
	      // ...
	    }).
	    matchEquals("print", s -> System.out.println(state) ).	//마지막 상태확인	    
	    match(String.class, cmd -> {
	      persist( "evt-" + cmd, e -> {
	log.info("EventFired:"+cmd);	 
            state  updateState(e);
= "MyState" + cmd;   	
	        if (lastSequenceNr() % snapShotInterval == 0 && lastSequenceNr() != 0)
		          saveSnapshot(state);
//이벤트가 5회 발생할때마다 스냅샷을 찍음
	        	  log.info("SaveSnapShot");
                  
		      }    saveSnapshot(state);
	    })	    
	    .build();
	}
}