Class EventsByPersistenceIdPublisher
- java.lang.Object
-
- akka.persistence.query.journal.leveldb.EventsByPersistenceIdPublisher
-
public class EventsByPersistenceIdPublisher extends java.lang.Object
INTERNAL API
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
EventsByPersistenceIdPublisher.Continue$
INTERNAL API
-
Constructor Summary
Constructors Constructor Description EventsByPersistenceIdPublisher()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static Props
props(java.lang.String persistenceId, long fromSequenceNr, long toSequenceNr, scala.Option<scala.concurrent.duration.FiniteDuration> refreshInterval, int maxBufSize, java.lang.String writeJournalPluginId)
-
-
-
Method Detail
-
props
public static Props props(java.lang.String persistenceId, long fromSequenceNr, long toSequenceNr, scala.Option<scala.concurrent.duration.FiniteDuration> refreshInterval, int maxBufSize, java.lang.String writeJournalPluginId)
-
-