Package | Description |
---|---|
io.axoniq.axonserver.grpc.query | |
org.axonframework.axonserver.connector.query.subscription |
Modifier and Type | Method and Description |
---|---|
SubscriptionQuery |
SubscriptionQuery.Builder.build() |
SubscriptionQuery |
SubscriptionQuery.Builder.buildPartial() |
static SubscriptionQuery |
SubscriptionQuery.getDefaultInstance() |
SubscriptionQuery |
SubscriptionQuery.getDefaultInstanceForType() |
SubscriptionQuery |
SubscriptionQuery.Builder.getDefaultInstanceForType() |
SubscriptionQuery |
SubscriptionQueryRequest.getFlowControl()
.io.axoniq.axonserver.grpc.query.SubscriptionQuery flow_control = 4; |
SubscriptionQuery |
SubscriptionQueryRequest.Builder.getFlowControl()
.io.axoniq.axonserver.grpc.query.SubscriptionQuery flow_control = 4; |
SubscriptionQuery |
SubscriptionQueryRequestOrBuilder.getFlowControl()
.io.axoniq.axonserver.grpc.query.SubscriptionQuery flow_control = 4; |
SubscriptionQuery |
SubscriptionQueryRequest.getGetInitialResult()
.io.axoniq.axonserver.grpc.query.SubscriptionQuery get_initial_result = 3; |
SubscriptionQuery |
SubscriptionQueryRequest.Builder.getGetInitialResult()
.io.axoniq.axonserver.grpc.query.SubscriptionQuery get_initial_result = 3; |
SubscriptionQuery |
SubscriptionQueryRequestOrBuilder.getGetInitialResult()
.io.axoniq.axonserver.grpc.query.SubscriptionQuery get_initial_result = 3; |
SubscriptionQuery |
SubscriptionQueryRequest.getSubscribe()
.io.axoniq.axonserver.grpc.query.SubscriptionQuery subscribe = 1; |
SubscriptionQuery |
SubscriptionQueryRequest.Builder.getSubscribe()
.io.axoniq.axonserver.grpc.query.SubscriptionQuery subscribe = 1; |
SubscriptionQuery |
SubscriptionQueryRequestOrBuilder.getSubscribe()
.io.axoniq.axonserver.grpc.query.SubscriptionQuery subscribe = 1; |
SubscriptionQuery |
SubscriptionQueryRequest.getUnsubscribe()
.io.axoniq.axonserver.grpc.query.SubscriptionQuery unsubscribe = 2; |
SubscriptionQuery |
SubscriptionQueryRequest.Builder.getUnsubscribe()
.io.axoniq.axonserver.grpc.query.SubscriptionQuery unsubscribe = 2; |
SubscriptionQuery |
SubscriptionQueryRequestOrBuilder.getUnsubscribe()
.io.axoniq.axonserver.grpc.query.SubscriptionQuery unsubscribe = 2; |
static SubscriptionQuery |
SubscriptionQuery.parseDelimitedFrom(InputStream input) |
static SubscriptionQuery |
SubscriptionQuery.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static SubscriptionQuery |
SubscriptionQuery.parseFrom(byte[] data) |
static SubscriptionQuery |
SubscriptionQuery.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static SubscriptionQuery |
SubscriptionQuery.parseFrom(ByteBuffer data) |
static SubscriptionQuery |
SubscriptionQuery.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static SubscriptionQuery |
SubscriptionQuery.parseFrom(com.google.protobuf.ByteString data) |
static SubscriptionQuery |
SubscriptionQuery.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static SubscriptionQuery |
SubscriptionQuery.parseFrom(com.google.protobuf.CodedInputStream input) |
static SubscriptionQuery |
SubscriptionQuery.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static SubscriptionQuery |
SubscriptionQuery.parseFrom(InputStream input) |
static SubscriptionQuery |
SubscriptionQuery.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<SubscriptionQuery> |
SubscriptionQuery.getParserForType() |
static com.google.protobuf.Parser<SubscriptionQuery> |
SubscriptionQuery.parser() |
Modifier and Type | Method and Description |
---|---|
SubscriptionQueryRequest.Builder |
SubscriptionQueryRequest.Builder.mergeFlowControl(SubscriptionQuery value)
.io.axoniq.axonserver.grpc.query.SubscriptionQuery flow_control = 4; |
SubscriptionQuery.Builder |
SubscriptionQuery.Builder.mergeFrom(SubscriptionQuery other) |
SubscriptionQueryRequest.Builder |
SubscriptionQueryRequest.Builder.mergeGetInitialResult(SubscriptionQuery value)
.io.axoniq.axonserver.grpc.query.SubscriptionQuery get_initial_result = 3; |
SubscriptionQueryRequest.Builder |
SubscriptionQueryRequest.Builder.mergeSubscribe(SubscriptionQuery value)
.io.axoniq.axonserver.grpc.query.SubscriptionQuery subscribe = 1; |
SubscriptionQueryRequest.Builder |
SubscriptionQueryRequest.Builder.mergeUnsubscribe(SubscriptionQuery value)
.io.axoniq.axonserver.grpc.query.SubscriptionQuery unsubscribe = 2; |
static SubscriptionQuery.Builder |
SubscriptionQuery.newBuilder(SubscriptionQuery prototype) |
SubscriptionQueryRequest.Builder |
SubscriptionQueryRequest.Builder.setFlowControl(SubscriptionQuery value)
.io.axoniq.axonserver.grpc.query.SubscriptionQuery flow_control = 4; |
SubscriptionQueryRequest.Builder |
SubscriptionQueryRequest.Builder.setGetInitialResult(SubscriptionQuery value)
.io.axoniq.axonserver.grpc.query.SubscriptionQuery get_initial_result = 3; |
SubscriptionQueryRequest.Builder |
SubscriptionQueryRequest.Builder.setSubscribe(SubscriptionQuery value)
.io.axoniq.axonserver.grpc.query.SubscriptionQuery subscribe = 1; |
SubscriptionQueryRequest.Builder |
SubscriptionQueryRequest.Builder.setUnsubscribe(SubscriptionQuery value)
.io.axoniq.axonserver.grpc.query.SubscriptionQuery unsubscribe = 2; |
Modifier and Type | Method and Description |
---|---|
SubscriptionQuery |
SubscriptionMessageSerializer.serialize(SubscriptionQueryMessage subscriptionQueryMessage)
Convert a
SubscriptionQueryMessage into a SubscriptionQuery . |
Constructor and Description |
---|
AxonServerSubscriptionQueryResult(SubscriptionQuery subscriptionQuery,
Function<io.grpc.stub.StreamObserver<SubscriptionQueryResponse>,io.grpc.stub.StreamObserver<SubscriptionQueryRequest>> openStreamFn,
AxonServerConfiguration configuration,
SubscriptionQueryBackpressure backPressure,
int bufferSize,
Runnable onDispose)
Instantiate a
AxonServerSubscriptionQueryResult which will emit its initial response and the updates of
the subscription query. |
GrpcBackedSubscriptionQueryMessage(SubscriptionQuery subscriptionQuery,
Serializer messageSerializer,
Serializer serializer)
Instantiate a
GrpcBackedSubscriptionQueryMessage with the given subscriptionQuery , using the
provided messageSerializer to be able to retrieve the payload and MetaData from it. |
Copyright © 2010–2019. All rights reserved.