akka.persistence
Class JournalProtocol.ReplayMessages

java.lang.Object
  akka.persistence.JournalProtocol.ReplayMessages

All Implemented Interfaces:

java.io.Serializable, scala.Equals, scala.Product

Enclosing class:

JournalProtocol

public static class JournalProtocol.ReplayMessages
extends java.lang.Object
implements scala.Product, scala.Serializable

Request to replay messages to persistentActor.

param: fromSequenceNr sequence number where replay should start (inclusive). param: toSequenceNr sequence number where replay should end (inclusive). param: max maximum number of messages to be replayed. param: persistenceId requesting persistent actor id. param: persistentActor requesting persistent actor. param: replayDeleted true if messages marked as deleted shall be replayed.

See Also:

Serialized Form

Constructor Summary

JournalProtocol.ReplayMessages(long fromSequenceNr, long toSequenceNr, long max, java.lang.String persistenceId, ActorRef persistentActor, boolean replayDeleted)

Method Summary

long	fromSequenceNr()
long	max()
java.lang.String	persistenceId()
ActorRef	persistentActor()
boolean	replayDeleted()
long	toSequenceNr()

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Product

productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

JournalProtocol.ReplayMessages

public JournalProtocol.ReplayMessages(long fromSequenceNr,
                                      long toSequenceNr,
                                      long max,
                                      java.lang.String persistenceId,
                                      ActorRef persistentActor,
                                      boolean replayDeleted)

Method Detail

fromSequenceNr

public long fromSequenceNr()

toSequenceNr

public long toSequenceNr()

max

public long max()

persistenceId

public java.lang.String persistenceId()

persistentActor

public ActorRef persistentActor()

replayDeleted

public boolean replayDeleted()