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, wait
public 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()