io.axoniq.axonserver.grpc.command.Command command
LazyDeserializingObject<T> serializedPayload
Supplier<T> metaDataSupplier
String code
io.axoniq.axonserver.grpc.query.QueryRequest query
LazyDeserializingObject<T> serializedPayload
LazyDeserializingObject<T> serializedResponseType
Supplier<T> metaDataSupplier
io.axoniq.axonserver.grpc.query.QueryResponse queryResponse
LazyDeserializingObject<T> serializedPayload
Throwable exception
Supplier<T> metaDataSupplier
io.axoniq.axonserver.grpc.query.SubscriptionQuery subscriptionQuery
GrpcBackedQueryMessage<Q,R> grpcBackedQueryMessage
LazyDeserializingObject<T> serializedUpdateResponseType
String commandName
String commandIdentifier
byte[] serializedMetaData
String payloadType
String payloadRevision
byte[] serializedPayload
String exceptionType
String exceptionRevision
byte[] serializedException
CommandMessageFilter first
CommandMessageFilter second
CommandMessageFilter filter
CommandMessageFilter first
CommandMessageFilter second
private void readObject(ObjectInputStream objectInputStream) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private Object readResolve()
String deadlineName
String aggregateIdentifier
private Object readResolve()
org.joda.time.DateTime timestamp
TrackingToken trackingToken
TrackingToken trackingToken
long globalIndex
TrackingToken lowerSegmentToken
TrackingToken upperSegmentToken
TrackingToken tokenAtReset
TrackingToken currentToken
Object context
String tokenId
String processorName
int segment
Object aggregateRoot
Long version
boolean deleted
SnapshotTrigger snapshotTrigger
private Object readResolve()
long index
Collection<E> gaps
private Object readResolve()
long globalIndex
String identifier
Throwable exception
Object details
Member violatingMethod
ResponseType<R> expectedResponseType
QueryResponseMessage<T> responseMessage
InstanceResponseType<R> instanceResponseType
ResponseType<R> multipleInstanceResponseType
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–2023. All rights reserved.