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