public final class Update
extends java.lang.Object
implements scala.Product, scala.Serializable
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 event stream.
param: replayMax maximum number of messages to replay when handling this update request. Defaults
to Long.MaxValue (i.e. no limit).
| Constructor and Description |
|---|
Update(boolean await,
long replayMax) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
await() |
abstract static boolean |
canEqual(java.lang.Object that) |
static Update |
create()
Java API.
|
static Update |
create(boolean await)
Java API.
|
static Update |
create(boolean await,
long replayMax)
Java API.
|
abstract static boolean |
equals(java.lang.Object that) |
abstract static int |
productArity() |
abstract static java.lang.Object |
productElement(int n) |
static scala.collection.Iterator<java.lang.Object> |
productIterator() |
static java.lang.String |
productPrefix() |
long |
replayMax() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitpublic static Update create()
public static Update create(boolean await)
await - (undocumented)public static Update create(boolean await, long replayMax)
await - (undocumented)replayMax - (undocumented)public abstract static boolean canEqual(java.lang.Object that)
public abstract static boolean equals(java.lang.Object that)
public abstract static java.lang.Object productElement(int n)
public abstract static int productArity()
public static scala.collection.Iterator<java.lang.Object> productIterator()
public static java.lang.String productPrefix()
public boolean await()
public long replayMax()