Object messageId_
boolean success_
byte memoizedIsInitialized
int dataCase_
Object data_
byte memoizedIsInitialized
int key_
MetaDataValue value_
byte memoizedIsInitialized
int bitField0_
Object messageIdentifier_
Object name_
long timestamp_
SerializedObject payload_
com.google.protobuf.MapField<K,V> metaData_
List<E> processingInstructions_
Object clientId_
Object componentName_
byte memoizedIsInitialized
int requestCase_
Object request_
byte memoizedIsInitialized
int requestCase_
Object request_
byte memoizedIsInitialized
int bitField0_
Object messageIdentifier_
Object errorCode_
ErrorMessage errorMessage_
SerializedObject payload_
com.google.protobuf.MapField<K,V> metaData_
List<E> processingInstructions_
Object requestIdentifier_
byte memoizedIsInitialized
int segmentId_
boolean caughtUp_
boolean replaying_
int onePartOf_
byte memoizedIsInitialized
Object processorName_
byte memoizedIsInitialized
int requestCase_
Object request_
byte memoizedIsInitialized
NodeInfo primary_
boolean sameConnection_
byte memoizedIsInitialized
int requestCase_
Object request_
byte memoizedIsInitialized
Object processorName_
int segmentIdentifier_
byte memoizedIsInitialized
Object processorName_
byte memoizedIsInitialized
byte memoizedIsInitialized
Object processorName_
byte memoizedIsInitialized
com.google.protobuf.LazyStringList column_
byte memoizedIsInitialized
boolean success_
byte memoizedIsInitialized
int bitField0_
Object messageIdentifier_
Object aggregateIdentifier_
long aggregateSequenceNumber_
Object aggregateType_
long timestamp_
SerializedObject payload_
com.google.protobuf.MapField<K,V> metaData_
boolean snapshot_
byte memoizedIsInitialized
long token_
Event event_
byte memoizedIsInitialized
Object aggregateId_
long initialSequence_
boolean allowSnapshots_
byte memoizedIsInitialized
Object aggregateId_
long initialSequence_
long maxSequence_
int maxResults_
byte memoizedIsInitialized
byte memoizedIsInitialized
byte memoizedIsInitialized
long instant_
byte memoizedIsInitialized
Object query_
long numberOfPermits_
boolean liveEvents_
byte memoizedIsInitialized
int dataCase_
Object data_
byte memoizedIsInitialized
int dataCase_
Object data_
byte memoizedIsInitialized
Object aggregateId_
long fromSequenceNr_
byte memoizedIsInitialized
long toSequenceNr_
byte memoizedIsInitialized
byte memoizedIsInitialized
long token_
byte memoizedIsInitialized
int requestCase_
Object request_
byte memoizedIsInitialized
int requestCase_
Object request_
byte memoizedIsInitialized
int bitField0_
Object messageIdentifier_
Object query_
long timestamp_
SerializedObject payload_
com.google.protobuf.MapField<K,V> metaData_
SerializedObject responseType_
List<E> processingInstructions_
Object clientId_
Object componentName_
byte memoizedIsInitialized
int bitField0_
Object messageIdentifier_
Object errorCode_
ErrorMessage errorMessage_
SerializedObject payload_
com.google.protobuf.MapField<K,V> metaData_
List<E> processingInstructions_
Object requestIdentifier_
byte memoizedIsInitialized
int bitField0_
Object messageIdentifier_
SerializedObject payload_
com.google.protobuf.MapField<K,V> metaData_
Object clientId_
Object componentName_
byte memoizedIsInitialized
Object clientId_
Object componentName_
Object errorCode_
ErrorMessage errorMessage_
byte memoizedIsInitialized
Object subscriptionIdentifier_
long numberOfPermits_
QueryRequest queryRequest_
SerializedObject updateResponseType_
byte memoizedIsInitialized
Command request
Serializer serializer
MetaData metaData
String code
QueryRequest query
Serializer messageSerializer
LazyDeserializingObject<T> serializedPayload
LazyDeserializingObject<T> serializedResponseType
Supplier<T> metadata
QueryResponse queryResponse
Serializer messageSerializer
LazyDeserializingObject<T> serializedPayload
Throwable exception
Supplier<T> metadata
SubscriptionQuery subscriptionQuery
GrpcBackedQueryMessage<Q,R> grpcBackedQueryMessage
LazyDeserializingObject<T> updateType
String commandName
CommandMessageFilter first
CommandMessageFilter second
CommandMessageFilter filter
CommandMessageFilter first
CommandMessageFilter second
String deadlineName
String aggregateIdentifier
private Object readResolve()
org.joda.time.DateTime timestamp
TrackingToken trackingToken
TrackingToken trackingToken
long globalIndex
TrackingToken tokenAtReset
TrackingToken currentToken
String tokenId
String processorName
int segment
Object aggregateRoot
Long version
boolean deleted
SnapshotTrigger snapshotTrigger
String identifier
Throwable exception
Member violatingMethod
String aggregateIdentifier
String aggregateIdentifier
private void writeObject(ObjectOutputStream out) throws IOException
identifierSupplier
is
called, thus setting the identifier
, prior to serializing this AggregateScopeDescriptor.IOException
String aggregateIdentifier
long expectedVersion
long actualVersion
String queryName
ResponseType<R> responseType
ResponseType<R> updateResponseType
private void writeObject(ObjectOutputStream stream) throws IOException
CachingSupplier.get()
.IOException
AtomicReference<V> value
protected Object writeReplace()
LazyDeserializingObject<T> metaData
LazyDeserializingObject<T> payload
Instant scheduleTime
EventMessage<T> event
int counter
Copyright © 2010–2018. All rights reserved.