akka.persistence
Class Update
java.lang.Object
akka.persistence.Update
- All Implemented Interfaces:
- java.io.Serializable, scala.Equals, scala.Product
public class Update
- extends java.lang.Object
- implements scala.Product, scala.Serializable
Instructs a PersistentView
to update itself. This will run a single incremental message replay with
all messages from the corresponding persistent id's journal that have not yet been consumed by the view.
To update a view with messages that have been written after handling this request, another Update
request must be sent to the view.
param: await if true
, processing of further messages sent to the view will be delayed until the
incremental message replay, triggered by this update request, completes. If false
,
any message sent to the view may interleave with replayed Persistent
message
stream.
param: replayMax maximum number of messages to replay when handling this update request. Defaults
to Long.MaxValue
(i.e. no limit).
- See Also:
- Serialized Form
Constructor Summary |
Update(boolean await,
long replayMax)
|
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 |
Update
public Update(boolean await,
long replayMax)
create
public static Update create()
- Java API.
- Returns:
- (undocumented)
create
public static Update create(boolean await)
- Java API.
- Parameters:
await
- (undocumented)
- Returns:
- (undocumented)
create
public static Update create(boolean await,
long replayMax)
- Java API.
- Parameters:
await
- (undocumented)replayMax
- (undocumented)
- Returns:
- (undocumented)
await
public boolean await()
replayMax
public long replayMax()