Package | Description |
---|---|
io.axoniq.axonserver.grpc.query | |
org.axonframework.axonserver.connector.query | |
org.axonframework.axonserver.connector.query.subscription |
Modifier and Type | Method and Description |
---|---|
QueryResponse |
QueryResponse.Builder.build() |
QueryResponse |
QueryResponse.Builder.buildPartial() |
static QueryResponse |
QueryResponse.getDefaultInstance() |
QueryResponse |
QueryResponse.getDefaultInstanceForType() |
QueryResponse |
QueryResponse.Builder.getDefaultInstanceForType() |
QueryResponse |
SubscriptionQueryResponse.getInitialResult()
Provides an Initial Response
|
QueryResponse |
SubscriptionQueryResponse.Builder.getInitialResult()
Provides an Initial Response
|
QueryResponse |
SubscriptionQueryResponseOrBuilder.getInitialResult()
Provides an Initial Response
|
QueryResponse |
QueryProviderOutboundOrBuilder.getQueryResponse()
Sends a Response to a Query received via the inbound stream
|
QueryResponse |
QueryProviderOutbound.getQueryResponse()
Sends a Response to a Query received via the inbound stream
|
QueryResponse |
QueryProviderOutbound.Builder.getQueryResponse()
Sends a Response to a Query received via the inbound stream
|
static QueryResponse |
QueryResponse.parseDelimitedFrom(InputStream input) |
static QueryResponse |
QueryResponse.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static QueryResponse |
QueryResponse.parseFrom(byte[] data) |
static QueryResponse |
QueryResponse.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static QueryResponse |
QueryResponse.parseFrom(ByteBuffer data) |
static QueryResponse |
QueryResponse.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static QueryResponse |
QueryResponse.parseFrom(com.google.protobuf.ByteString data) |
static QueryResponse |
QueryResponse.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static QueryResponse |
QueryResponse.parseFrom(com.google.protobuf.CodedInputStream input) |
static QueryResponse |
QueryResponse.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static QueryResponse |
QueryResponse.parseFrom(InputStream input) |
static QueryResponse |
QueryResponse.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<QueryResponse> |
QueryResponse.getParserForType() |
static io.grpc.MethodDescriptor<QueryRequest,QueryResponse> |
QueryServiceGrpc.getQueryMethod() |
static com.google.protobuf.Parser<QueryResponse> |
QueryResponse.parser() |
Iterator<QueryResponse> |
QueryServiceGrpc.QueryServiceBlockingStub.query(QueryRequest request)
Sends a point-to-point or scatter-gather Query
|
Modifier and Type | Method and Description |
---|---|
QueryResponse.Builder |
QueryResponse.Builder.mergeFrom(QueryResponse other) |
SubscriptionQueryResponse.Builder |
SubscriptionQueryResponse.Builder.mergeInitialResult(QueryResponse value)
Provides an Initial Response
|
QueryProviderOutbound.Builder |
QueryProviderOutbound.Builder.mergeQueryResponse(QueryResponse value)
Sends a Response to a Query received via the inbound stream
|
static QueryResponse.Builder |
QueryResponse.newBuilder(QueryResponse prototype) |
SubscriptionQueryResponse.Builder |
SubscriptionQueryResponse.Builder.setInitialResult(QueryResponse value)
Provides an Initial Response
|
QueryProviderOutbound.Builder |
QueryProviderOutbound.Builder.setQueryResponse(QueryResponse value)
Sends a Response to a Query received via the inbound stream
|
Modifier and Type | Method and Description |
---|---|
void |
QueryServiceGrpc.QueryServiceImplBase.query(QueryRequest request,
io.grpc.stub.StreamObserver<QueryResponse> responseObserver)
Sends a point-to-point or scatter-gather Query
|
void |
QueryServiceGrpc.QueryServiceStub.query(QueryRequest request,
io.grpc.stub.StreamObserver<QueryResponse> responseObserver)
Sends a point-to-point or scatter-gather Query
|
Modifier and Type | Method and Description |
---|---|
QueryResponse |
QuerySerializer.serializeResponse(QueryResponseMessage<?> queryResponse,
String requestMessageId)
Convert a
QueryResponseMessage into a QueryResponse . |
Modifier and Type | Method and Description |
---|---|
<R> QueryResponseMessage<R> |
QuerySerializer.deserializeResponse(QueryResponse queryResponse,
ResponseType<R> expectedResponseType)
Convert a
QueryResponse into a QueryResponseMessage . |
Constructor and Description |
---|
GrpcBackedResponseMessage(QueryResponse queryResponse,
Serializer serializer)
Instantiate a
GrpcBackedResponseMessage with the given queryResponse , using the provided
Serializer to be able to retrieve the payload and MetaData from it. |
Modifier and Type | Method and Description |
---|---|
SubscriptionQueryResult<QueryResponse,QueryUpdate> |
AxonServerSubscriptionQueryResult.get() |
Constructor and Description |
---|
DeserializedResult(SubscriptionQueryResult<QueryResponse,QueryUpdate> delegate,
SubscriptionMessageSerializer serializer)
Instantiate a
DeserializedResult wrapping the delegate which will be serialized by the given
serializer . |
Copyright © 2010–2020. All rights reserved.