Page History

//메이븐 설정
		<dependency>
		  <groupId>com.typesafe.akka</groupId>
		  <artifactId>akka-persistence_2.12</artifactId>
		  <version>${akka.version}</version>
		</dependency>		  
		
		<dependency>
			<groupId>org.fusesource.leveldbjni</groupId>
  			<artifactId>leveldbjni-all</artifactId>
  			<version>1.8</version>  
		</dependency>




//Akka Persistence설정 : 다양한 복구옵션과 다양한 저장장치선택이 가능합니다. 여기서는 기본 local-disk 장치를 이용합니다.
//작동중에만 고성능으로 영속성을 사용한다고하면  akka.persistence.journal.inmem 로 설정만 교체하면 되며
//영구 저장은 스냅샷 전략을 통해 db에 저장이 가능합니다.
akka{
	extensions = [akka.persistence.Persistence]
	  persistence {	  
	    journal {
	      plugin = "akka.persistence.journal.leveldb"
	      auto-start-journals = ["akka.persistence.journal.leveldb"]
	    }
	    snapshot-store {
	      plugin = "akka.persistence.snapshot-store.local"
	      auto-start-snapshot-stores = ["akka.persistence.snapshot-store.local"]
	    }	
	  }	
}

의도적으로 드랍한 메시지가 결국 성공됨을 확인할수가 있습니다.

drop msg for test:861
msg ok :872
drop msg for test:883
msg ok :894
drop msg for test:905
msg ok :916
drop msg for test:927
msg ok :938
drop msg for test:949
msg ok :9510
drop msg for test:861
msg ok :883
drop msg for test:905
msg ok :927
drop msg for test:949
msg ok :861
drop msg for test:905
msg ok :949
drop msg for test:905
msg ok :905