akka.persistence.query.journal.leveldb

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 and Description
static class	EventsByPersistenceIdPublisher.Continue$ INTERNAL API

Constructor Summary

Constructors

Constructor and Description
EventsByPersistenceIdPublisher()

Method Summary

Modifier and Type	Method and 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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EventsByPersistenceIdPublisher

public EventsByPersistenceIdPublisher()

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)