Uses of Class
io.axoniq.axonserver.grpc.query.QueryUpdate
-
Packages that use QueryUpdate Package Description io.axoniq.axonserver.connector.query io.axoniq.axonserver.connector.query.impl io.axoniq.axonserver.grpc.query -
-
Uses of QueryUpdate in io.axoniq.axonserver.connector.query
Methods in io.axoniq.axonserver.connector.query that return types with arguments of type QueryUpdate Modifier and Type Method Description ResultStream<QueryUpdate>SubscriptionQueryResult. updates()Returns the stream of updates to the queried projection.Methods in io.axoniq.axonserver.connector.query with parameters of type QueryUpdate Modifier and Type Method Description voidQueryHandler.UpdateHandler. sendUpdate(QueryUpdate queryUpdate)Send the givenqueryUpdatein response to the subscription query this handler was provided for. -
Uses of QueryUpdate in io.axoniq.axonserver.connector.query.impl
Methods in io.axoniq.axonserver.connector.query.impl that return QueryUpdate Modifier and Type Method Description protected QueryUpdateSubscriptionQueryUpdateBuffer. terminalMessage()Methods in io.axoniq.axonserver.connector.query.impl that return types with arguments of type QueryUpdate Modifier and Type Method Description ResultStream<QueryUpdate>SubscriptionQueryStream. updatesBuffer()Returns theResultStreambuffering theQueryUpdates to this subscription query.Methods in io.axoniq.axonserver.connector.query.impl with parameters of type QueryUpdate Modifier and Type Method Description voidSubscriptionQueryUpdateBuffer. onNext(QueryUpdate value) -
Uses of QueryUpdate in io.axoniq.axonserver.grpc.query
Methods in io.axoniq.axonserver.grpc.query that return QueryUpdate Modifier and Type Method Description QueryUpdateQueryUpdate.Builder. build()QueryUpdateQueryUpdate.Builder. buildPartial()static QueryUpdateQueryUpdate. getDefaultInstance()QueryUpdateQueryUpdate.Builder. getDefaultInstanceForType()QueryUpdateQueryUpdate. getDefaultInstanceForType()QueryUpdateSubscriptionQueryResponse.Builder. getUpdate()Provides an Update ResponseQueryUpdateSubscriptionQueryResponse. getUpdate()Provides an Update ResponseQueryUpdateSubscriptionQueryResponseOrBuilder. getUpdate()Provides an Update Responsestatic QueryUpdateQueryUpdate. parseDelimitedFrom(InputStream input)static QueryUpdateQueryUpdate. parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static QueryUpdateQueryUpdate. parseFrom(byte[] data)static QueryUpdateQueryUpdate. parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static QueryUpdateQueryUpdate. parseFrom(com.google.protobuf.ByteString data)static QueryUpdateQueryUpdate. parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static QueryUpdateQueryUpdate. parseFrom(com.google.protobuf.CodedInputStream input)static QueryUpdateQueryUpdate. parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static QueryUpdateQueryUpdate. parseFrom(InputStream input)static QueryUpdateQueryUpdate. parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static QueryUpdateQueryUpdate. parseFrom(ByteBuffer data)static QueryUpdateQueryUpdate. parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)Methods in io.axoniq.axonserver.grpc.query that return types with arguments of type QueryUpdate Modifier and Type Method Description com.google.protobuf.Parser<QueryUpdate>QueryUpdate. getParserForType()static com.google.protobuf.Parser<QueryUpdate>QueryUpdate. parser()Methods in io.axoniq.axonserver.grpc.query with parameters of type QueryUpdate Modifier and Type Method Description QueryUpdate.BuilderQueryUpdate.Builder. mergeFrom(QueryUpdate other)SubscriptionQueryResponse.BuilderSubscriptionQueryResponse.Builder. mergeUpdate(QueryUpdate value)Provides an Update Responsestatic QueryUpdate.BuilderQueryUpdate. newBuilder(QueryUpdate prototype)SubscriptionQueryResponse.BuilderSubscriptionQueryResponse.Builder. setUpdate(QueryUpdate value)Provides an Update Response
-