Uses of Class
io.axoniq.axonserver.grpc.query.QueryProviderInbound

Packages that use QueryProviderInbound

Package	Description
io.axoniq.axonserver.grpc.query
org.axonframework.axonserver.connector
org.axonframework.axonserver.connector.query
org.axonframework.axonserver.connector.query.subscription

Uses of QueryProviderInbound in io.axoniq.axonserver.grpc.query

Methods in io.axoniq.axonserver.grpc.query that return QueryProviderInbound

Modifier and Type	Method and Description
QueryProviderInbound	QueryProviderInbound.Builder.build()
QueryProviderInbound	QueryProviderInbound.Builder.buildPartial()
static QueryProviderInbound	QueryProviderInbound.getDefaultInstance()
QueryProviderInbound	QueryProviderInbound.getDefaultInstanceForType()
QueryProviderInbound	QueryProviderInbound.Builder.getDefaultInstanceForType()
static QueryProviderInbound	QueryProviderInbound.parseDelimitedFrom(InputStream input)
static QueryProviderInbound	QueryProviderInbound.parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static QueryProviderInbound	QueryProviderInbound.parseFrom(byte[] data)
static QueryProviderInbound	QueryProviderInbound.parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static QueryProviderInbound	QueryProviderInbound.parseFrom(ByteBuffer data)
static QueryProviderInbound	QueryProviderInbound.parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static QueryProviderInbound	QueryProviderInbound.parseFrom(com.google.protobuf.ByteString data)
static QueryProviderInbound	QueryProviderInbound.parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static QueryProviderInbound	QueryProviderInbound.parseFrom(com.google.protobuf.CodedInputStream input)
static QueryProviderInbound	QueryProviderInbound.parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static QueryProviderInbound	QueryProviderInbound.parseFrom(InputStream input)
static QueryProviderInbound	QueryProviderInbound.parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)

Methods in io.axoniq.axonserver.grpc.query that return types with arguments of type QueryProviderInbound

Modifier and Type	Method and Description
static io.grpc.MethodDescriptor<QueryProviderOutbound,QueryProviderInbound>	QueryServiceGrpc.getOpenStreamMethod()
com.google.protobuf.Parser<QueryProviderInbound>	QueryProviderInbound.getParserForType()
static com.google.protobuf.Parser<QueryProviderInbound>	QueryProviderInbound.parser()

Methods in io.axoniq.axonserver.grpc.query with parameters of type QueryProviderInbound

Modifier and Type	Method and Description
QueryProviderInbound.Builder	QueryProviderInbound.Builder.mergeFrom(QueryProviderInbound other)
static QueryProviderInbound.Builder	QueryProviderInbound.newBuilder(QueryProviderInbound prototype)

Method parameters in io.axoniq.axonserver.grpc.query with type arguments of type QueryProviderInbound

Modifier and Type	Method and Description
io.grpc.stub.StreamObserver<QueryProviderOutbound>	QueryServiceGrpc.QueryServiceImplBase.openStream(io.grpc.stub.StreamObserver<QueryProviderInbound> responseObserver) Opens a Query- and Instruction stream to AxonServer.
io.grpc.stub.StreamObserver<QueryProviderOutbound>	QueryServiceGrpc.QueryServiceStub.openStream(io.grpc.stub.StreamObserver<QueryProviderInbound> responseObserver) Opens a Query- and Instruction stream to AxonServer.

Uses of QueryProviderInbound in org.axonframework.axonserver.connector

Method parameters in org.axonframework.axonserver.connector with type arguments of type QueryProviderInbound

Modifier and Type	Method and Description
io.grpc.stub.StreamObserver<QueryProviderOutbound>	AxonServerConnectionManager.getQueryStream(String context, io.grpc.stub.StreamObserver<QueryProviderInbound> inboundQueryStream) Opens a Stream for incoming queries from AxonServer in the given context.

Uses of QueryProviderInbound in org.axonframework.axonserver.connector.query

Method parameters in org.axonframework.axonserver.connector.query with type arguments of type QueryProviderInbound

Modifier and Type	Method and Description
AxonServerQueryBus.Builder	AxonServerQueryBus.Builder.requestStreamFactory(Function<UpstreamAwareStreamObserver<QueryProviderInbound>,io.grpc.stub.StreamObserver<QueryProviderOutbound>> requestStreamFactory) Sets the request stream factory that creates a request stream based on upstream.

Uses of QueryProviderInbound in org.axonframework.axonserver.connector.query.subscription

Methods in org.axonframework.axonserver.connector.query.subscription with parameters of type QueryProviderInbound

Modifier and Type	Method and Description
void	SubscriptionQueryRequestTarget.onSubscriptionQueryRequest(String context, QueryProviderInbound queryProviderInbound) Decides, based on the wrapped SubscriptionQueryRequest returned from the given QueryProviderInbound, what operation to perform.