1.6.2

Durable Store will track the creation date and updated date.

1.6.0

Support for DurableStateStore

1.5.3

Filter Events by some Event's Attribute

From regular stream

val readJournal = ReactiveMongoJournalProvider(system).readJournalFor(Seq("Orders"))
readJournal
  .currentEventsByTags(Seq("TAG"), NoOffset, BSONDocument("events.p.customerId" -> customerId), None)
  .mapAsyc(envelope => someEventualWork(envelope))
  .run()

From non-termination stream

val readJournal = ReactiveMongoJournalProvider(system).readJournalFor(Seq("Orders"))
readJournal
  .eventsByTags(Seq("TAG"), NoOffset, BSONDocument("events.p.customerId" -> customerId), None, 5.seconds)
  .mapAsyc(envelope => someEventualWork(envelope) )
  .run()

1.5.2

v1.5.2

Important fix using indices in events by tag.

1.5.1

v1.5.1

Supporting #withTagger() of typed persistence.

1.5.0

v1.5.0

new event serializer

1.4.7

v1.4.7

Using hint for recovery

1.4.6

v1.4.6

driver connection

1.4.5

Enhance indices usage.

1.4.4

v1.4.4

Fix memory leak using non-termination persistence query.