carrot-garden / akka_eventstore.akka.persistence

Event Store Journal for Akka Persistence

Event Store Journal and Snapshot Store for Akka Persistence

Akka Persistence journal and snapshot-store backed by Event Store.

Scala	2.10.4/2.11.2
Akka	2.3.6
eventstore-client	1.0.1

To use this plugin prior default one, add the following to application.conf:

akka.persistence {
  journal.plugin = eventstore.persistence.journal
  snapshot-store.plugin = eventstore.persistence.snapshot-store
}

To configure EventStore.JVM client, see it's reference.conf

JSON serialization

Akka serializes your messages into binary data by default. However you can add your own serializer to serialize as JSON, But make sure you extend akka.persistence.eventstore.EventStoreSerializer rather then akka.serialization.Serializer. And in case you are really going to serialize as json, please specify ContentType.Json, it will allow you to use projections.

trait EventStoreSerializer extends Serializer {
  def toEvent(o: AnyRef): EventData
  def fromEvent(event: Event, manifest: Class[_]): AnyRef
}

Please check out some real examples used in tests:

• json4s
• spray-json

Setup

• Maven:

Add to pom.xml

    <dependency>
        <groupId>com.geteventstore</groupId>
        <artifactId>akka-persistence-eventstore_2.11</artifactId>
        <version>1.1.0</version>
    </dependency>

• Sbt

Add to build.sbt

    libraryDependencies += "com.geteventstore" %% "akka-persistence-eventstore" % "1.1.0"